Share via

CoreMessageSender Class

  • Reference
Package:
com.microsoft.azure.servicebus.primitives
  • java.lang.Object
    • ClientEntity
      • com.microsoft.azure.servicebus.primitives.CoreMessageSender

public class CoreMessageSender extends ClientEntity

Method Summary

Modifier and Type Method and Description
CompletableFuture<Void> cancelScheduledMessageAsync(Long[] sequenceNumbers, Duration timeout)
CompletableFuture<CoreMessageSender> create(final MessagingFactory factory, final String clientId, final String senderPath, final String transferDestinationPath)
CompletableFuture<CoreMessageSender> create(final MessagingFactory factory, final String clientId, final String senderPath, final String transferDestinationPath, final MessagingEntityType entityType)
ErrorContext getContext()
String getSendPath()
CompletableFuture<Void> onClose()
void onClose(ErrorCondition condition)
void onError(Exception completionException)
void onFlow(final int creditIssued)
void onOpenComplete(Exception completionException)
void onSendComplete(final Delivery delivery)
CompletableFuture<Collection<Message>> peekMessagesAsync(long fromSequenceNumber, int messageCount)
CompletableFuture<long[]> scheduleMessageAsync(Message[] messages, TransactionContext transaction, Duration timeout)
CompletableFuture<Void> sendAsync(final Iterable<Message> messages, TransactionContext transaction)
CompletableFuture<Void> sendAsync(Message msg, TransactionContext transaction)

Inherited Members

ClientEntity.ClientEntity(final String clientId) ClientEntity.close() ClientEntity.closeAsync() ClientEntity.finalize() ClientEntity.getClientId() ClientEntity.getIsClosed() ClientEntity.getIsClosingOrClosed() ClientEntity.setClosed() ClientEntity.throwIfClosed(Throwable cause)

Method Details

cancelScheduledMessageAsync

public CompletableFuture cancelScheduledMessageAsync(Long[] sequenceNumbers, Duration timeout)

Parameters:

sequenceNumbers
timeout

create

public static CompletableFuture create(final MessagingFactory factory, final String clientId, final String senderPath, final String transferDestinationPath)

Parameters:

factory
clientId
senderPath
transferDestinationPath

create

public static CompletableFuture create(final MessagingFactory factory, final String clientId, final String senderPath, final String transferDestinationPath, final MessagingEntityType entityType)

Parameters:

factory
clientId
senderPath
transferDestinationPath
entityType

getContext

public ErrorContext getContext()

getSendPath

public String getSendPath()

onClose

protected CompletableFuture onClose()

onClose

public void onClose(ErrorCondition condition)

Parameters:

condition

onError

public void onError(Exception completionException)

Parameters:

completionException

onFlow

public void onFlow(final int creditIssued)

Parameters:

creditIssued

onOpenComplete

public void onOpenComplete(Exception completionException)

Parameters:

completionException

onSendComplete

public void onSendComplete(final Delivery delivery)

Parameters:

delivery

peekMessagesAsync

public CompletableFuture> peekMessagesAsync(long fromSequenceNumber, int messageCount)

Parameters:

fromSequenceNumber
messageCount

scheduleMessageAsync

public CompletableFuture scheduleMessageAsync(Message[] messages, TransactionContext transaction, Duration timeout)

Parameters:

messages
transaction
timeout

sendAsync

public CompletableFuture sendAsync(final Iterable messages, TransactionContext transaction)

Parameters:

messages
transaction

sendAsync

public CompletableFuture sendAsync(Message msg, TransactionContext transaction)

Parameters:

msg
transaction

Applies to