void |
IMessageAndSessionPump.abandon(UUID lockToken) |
|
void |
IMessageAndSessionPump.abandon(UUID lockToken,
TransactionContext transaction) |
|
void |
IMessageAndSessionPump.abandon(UUID lockToken,
Map<String,Object> propertiesToModify) |
Abandon Message with lock token and updated message property.
|
void |
IMessageAndSessionPump.abandon(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
Abandon Message with lock token and updated message property.
|
void |
IMessageReceiver.abandon(UUID lockToken) |
|
void |
IMessageReceiver.abandon(UUID lockToken,
TransactionContext transaction) |
|
void |
IMessageReceiver.abandon(UUID lockToken,
Map<String,Object> propertiesToModify) |
Abandon Message with lock token and updated message property.
|
void |
IMessageReceiver.abandon(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
Abandon Message with lock token and updated message property.
|
void |
QueueClient.abandon(UUID lockToken) |
|
void |
QueueClient.abandon(UUID lockToken,
TransactionContext transaction) |
|
void |
QueueClient.abandon(UUID lockToken,
Map<String,Object> propertiesToModify) |
|
void |
QueueClient.abandon(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
|
void |
SubscriptionClient.abandon(UUID lockToken) |
|
void |
SubscriptionClient.abandon(UUID lockToken,
TransactionContext transaction) |
|
void |
SubscriptionClient.abandon(UUID lockToken,
Map<String,Object> propertiesToModify) |
|
void |
SubscriptionClient.abandon(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
|
static IMessageSession |
ClientFactory.acceptSessionFromConnectionString(String amqpConnectionString,
String sessionId) |
|
static IMessageSession |
ClientFactory.acceptSessionFromConnectionString(String amqpConnectionString,
String sessionId,
ReceiveMode receiveMode) |
Accept a IMessageSession from service bus connection string with specified session id.
|
static IMessageSession |
ClientFactory.acceptSessionFromConnectionStringBuilder(ConnectionStringBuilder amqpConnectionStringBuilder,
String sessionId) |
|
static IMessageSession |
ClientFactory.acceptSessionFromConnectionStringBuilder(ConnectionStringBuilder amqpConnectionStringBuilder,
String sessionId,
ReceiveMode receiveMode) |
Accept a IMessageSession from service bus connection string builder with specified session id.
|
static IMessageSession |
ClientFactory.acceptSessionFromEntityPath(MessagingFactory messagingFactory,
String entityPath,
String sessionId) |
Accept a IMessageSession from service bus using the client settings with specified session id.
|
static IMessageSession |
ClientFactory.acceptSessionFromEntityPath(MessagingFactory messagingFactory,
String entityPath,
String sessionId,
ReceiveMode receiveMode) |
Accept a IMessageSession from service bus using the client settings with specified session id.
|
static IMessageSession |
ClientFactory.acceptSessionFromEntityPath(String namespaceName,
String entityPath,
String sessionId,
ClientSettings clientSettings) |
Accept a IMessageSession from service bus using the client settings with specified session id in PeekLock mode.
|
static IMessageSession |
ClientFactory.acceptSessionFromEntityPath(String namespaceName,
String entityPath,
String sessionId,
ClientSettings clientSettings,
ReceiveMode receiveMode) |
Accept a IMessageSession from service bus using the client settings with specified session id.
|
static IMessageSession |
ClientFactory.acceptSessionFromEntityPath(URI namespaceEndpointURI,
String entityPath,
String sessionId,
ClientSettings clientSettings) |
Accept a IMessageSession from service bus using the client settings with specified session id in PeekLock mode.
|
static IMessageSession |
ClientFactory.acceptSessionFromEntityPath(URI namespaceEndpointURI,
String entityPath,
String sessionId,
ClientSettings clientSettings,
ReceiveMode receiveMode) |
Accept a IMessageSession from service bus using the client settings with specified session id.
|
void |
ISubscriptionClient.addRule(RuleDescription ruleDescription) |
Adds a rule to the current subscription to filter the messages reaching from topic to the subscription.
|
void |
ISubscriptionClient.addRule(String ruleName,
Filter filter) |
Adds a rule with specified name and Filter to the current subscription to filter the messages reaching from topic to the subscription.
|
void |
SubscriptionClient.addRule(RuleDescription ruleDescription) |
|
void |
SubscriptionClient.addRule(String ruleName,
Filter filter) |
|
void |
IMessageSender.cancelScheduledMessage(long sequenceNumber) |
Cancels the enqueuing of an already sent scheduled message, if it was not already enqueued.
|
void |
QueueClient.cancelScheduledMessage(long sequenceNumber) |
|
void |
TopicClient.cancelScheduledMessage(long sequenceNumber) |
|
void |
ICloseable.close() |
Synchronously closes and disposes any resources associated with this object.
|
void |
TransactionContext.commit() |
Commits the transaction
|
void |
IMessageAndSessionPump.complete(UUID lockToken) |
Completes a Message using its lock token.
|
void |
IMessageAndSessionPump.complete(UUID lockToken,
TransactionContext transaction) |
Completes a Message using its lock token.
|
void |
IMessageReceiver.complete(UUID lockToken) |
Completes a Message using its lock token.
|
void |
IMessageReceiver.complete(UUID lockToken,
TransactionContext transaction) |
Completes a Message using its lock token.
|
void |
QueueClient.complete(UUID lockToken) |
|
void |
QueueClient.complete(UUID lockToken,
TransactionContext transaction) |
|
void |
SubscriptionClient.complete(UUID lockToken) |
|
void |
SubscriptionClient.complete(UUID lockToken,
TransactionContext transaction) |
|
static <T> T |
Utils.completeFuture(CompletableFuture<T> future) |
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromConnectionString(String amqpConnectionString) |
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromConnectionString(String amqpConnectionString,
ReceiveMode receiveMode) |
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromConnectionStringBuilder(ConnectionStringBuilder amqpConnectionStringBuilder) |
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromConnectionStringBuilder(ConnectionStringBuilder amqpConnectionStringBuilder,
ReceiveMode receiveMode) |
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromEntityPath(MessagingFactory messagingFactory,
String entityPath) |
Creates a message receiver to the entity.
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromEntityPath(MessagingFactory messagingFactory,
String entityPath,
ReceiveMode receiveMode) |
Creates a message receiver to the entity.
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromEntityPath(String namespaceName,
String entityPath,
ClientSettings clientSettings) |
Creates a message receiver to the entity using the client settings in PeekLock mode
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromEntityPath(String namespaceName,
String entityPath,
ClientSettings clientSettings,
ReceiveMode receiveMode) |
Creates a message receiver to the entity using the client settings.
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromEntityPath(URI namespaceEndpointURI,
String entityPath,
ClientSettings clientSettings) |
Creates a message receiver to the entity using the client settings in PeekLock mode
|
static IMessageReceiver |
ClientFactory.createMessageReceiverFromEntityPath(URI namespaceEndpointURI,
String entityPath,
ClientSettings clientSettings,
ReceiveMode receiveMode) |
Creates a message receiver to the entity using the client settings.
|
static IMessageSender |
ClientFactory.createMessageSenderFromConnectionString(String amqpConnectionString) |
|
static IMessageSender |
ClientFactory.createMessageSenderFromConnectionStringBuilder(ConnectionStringBuilder amqpConnectionStringBuilder) |
Create message sender from ConnectionStringBuilder
|
static IMessageSender |
ClientFactory.createMessageSenderFromEntityPath(MessagingFactory messagingFactory,
String entityPath) |
Creates a message sender to the entity.
|
static IMessageSender |
ClientFactory.createMessageSenderFromEntityPath(String namespaceName,
String entityPath,
ClientSettings clientSettings) |
Creates a message sender to the entity using the client settings.
|
static IMessageSender |
ClientFactory.createMessageSenderFromEntityPath(URI namespaceEndpointURI,
String entityPath,
ClientSettings clientSettings) |
Creates a message sender to the entity using the client settings.
|
static IMessageSender |
ClientFactory.createTransferMessageSenderFromEntityPath(MessagingFactory messagingFactory,
String entityPath,
String viaEntityPath) |
Creates a transfer message sender.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken) |
Moves a Message to the deadletter sub-queue.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description and modified properties.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description and modified properties.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify) |
Moves a Message to the deadletter sub-queue with modified message properties.
|
void |
IMessageAndSessionPump.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue with modified message properties.
|
void |
IMessageReceiver.deadLetter(UUID lockToken) |
Moves a Message to the deadletter sub-queue.
|
void |
IMessageReceiver.deadLetter(UUID lockToken,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue.
|
void |
IMessageReceiver.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description.
|
void |
IMessageReceiver.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description.
|
void |
IMessageReceiver.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description and modified properties.
|
void |
IMessageReceiver.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue with deadletter reason and error description and modified properties.
|
void |
IMessageReceiver.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify) |
Moves a Message to the deadletter sub-queue with modified message properties.
|
void |
IMessageReceiver.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
Moves a Message to the deadletter sub-queue with modified message properties.
|
void |
QueueClient.deadLetter(UUID lockToken) |
|
void |
QueueClient.deadLetter(UUID lockToken,
TransactionContext transaction) |
|
void |
QueueClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription) |
|
void |
QueueClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
TransactionContext transaction) |
|
void |
QueueClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify) |
|
void |
QueueClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
|
void |
QueueClient.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify) |
|
void |
QueueClient.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken,
TransactionContext transaction) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
TransactionContext transaction) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken,
String deadLetterReason,
String deadLetterErrorDescription,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify) |
|
void |
SubscriptionClient.deadLetter(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
|
void |
IMessageReceiver.defer(UUID lockToken) |
Defers a Message using its lock token.
|
void |
IMessageReceiver.defer(UUID lockToken,
TransactionContext transaction) |
Defers a Message using its lock token.
|
void |
IMessageReceiver.defer(UUID lockToken,
Map<String,Object> propertiesToModify) |
Defers a Message using its lock token with modified message property.
|
void |
IMessageReceiver.defer(UUID lockToken,
Map<String,Object> propertiesToModify,
TransactionContext transaction) |
Defers a Message using its lock token with modified message property.
|
Collection<IMessageSession> |
IMessageSessionEntity.getMessageSessions() |
Gets the message sessions, enabling you to browse sessions on queues.
|
Collection<IMessageSession> |
IMessageSessionEntity.getMessageSessions(Instant lastUpdatedTime) |
Retrieves all message sessions whose session state was updated since lastUpdatedTime.
|
Collection<RuleDescription> |
ISubscriptionClient.getRules() |
Get all rules associated with the subscription.
|
Collection<RuleDescription> |
SubscriptionClient.getRules() |
|
byte[] |
IMessageSession.getState() |
Gets the session state.
|
byte[] |
MessageSession.getState() |
|
IMessage |
IMessageBrowser.peek() |
reads next the active message without changing the state of the receiver or the message source.
|
IMessage |
IMessageBrowser.peek(long fromSequenceNumber) |
Reads next the active message without changing the state of the receiver or the message source.
|
IMessage |
TopicClient.peek() |
|
IMessage |
TopicClient.peek(long fromSequenceNumber) |
|
Collection<IMessage> |
IMessageBrowser.peekBatch(int messageCount) |
Reads next batch of the active messages without changing the state of the receiver or the message source.
|
Collection<IMessage> |
IMessageBrowser.peekBatch(long fromSequenceNumber,
int messageCount) |
Reads next batch of the active messages without changing the state of the receiver or the message source.
|
Collection<IMessage> |
TopicClient.peekBatch(int messageCount) |
|
Collection<IMessage> |
TopicClient.peekBatch(long fromSequenceNumber,
int messageCount) |
|
IMessage |
IMessageReceiver.receive() |
Receives a Message with default server wait time.
|
IMessage |
IMessageReceiver.receive(Duration serverWaitTime) |
Receives a Message with specified server wait time.
|
Collection<IMessage> |
IMessageReceiver.receiveBatch(int maxMessageCount) |
Receives a maximum of maxMessageCount Message from Azure Service Bus.
|
Collection<IMessage> |
IMessageReceiver.receiveBatch(int maxMessageCount,
Duration serverWaitTime) |
Receives a maximum of maxMessageCount Message from Azure Service Bus with server wait time.
|
IMessage |
IMessageReceiver.receiveDeferredMessage(long sequenceNumber) |
|
Collection<IMessage> |
IMessageReceiver.receiveDeferredMessageBatch(Collection<Long> sequenceNumbers) |
Receives a batch of deferred Message .
|
void |
IMessageAndSessionPump.registerMessageHandler(IMessageHandler handler) |
Deprecated.
|
void |
IMessageAndSessionPump.registerMessageHandler(IMessageHandler handler,
MessageHandlerOptions handlerOptions) |
Deprecated.
|
void |
IMessageAndSessionPump.registerMessageHandler(IMessageHandler handler,
MessageHandlerOptions handlerOptions,
ExecutorService executorService) |
Receive messages continuously from the entity.
|
void |
IMessageAndSessionPump.registerMessageHandler(IMessageHandler handler,
ExecutorService executorService) |
Receive messages continuously from the entity.
|
void |
QueueClient.registerMessageHandler(IMessageHandler handler) |
Deprecated.
|
void |
QueueClient.registerMessageHandler(IMessageHandler handler,
MessageHandlerOptions handlerOptions) |
Deprecated.
|
void |
QueueClient.registerMessageHandler(IMessageHandler handler,
MessageHandlerOptions handlerOptions,
ExecutorService executorService) |
|
void |
QueueClient.registerMessageHandler(IMessageHandler handler,
ExecutorService executorService) |
|
void |
SubscriptionClient.registerMessageHandler(IMessageHandler handler) |
Deprecated.
|
void |
SubscriptionClient.registerMessageHandler(IMessageHandler handler,
MessageHandlerOptions handlerOptions) |
Deprecated.
|
void |
SubscriptionClient.registerMessageHandler(IMessageHandler handler,
MessageHandlerOptions handlerOptions,
ExecutorService executorService) |
|
void |
SubscriptionClient.registerMessageHandler(IMessageHandler handler,
ExecutorService executorService) |
|
void |
IMessageAndSessionPump.registerSessionHandler(ISessionHandler handler) |
Deprecated.
|
void |
IMessageAndSessionPump.registerSessionHandler(ISessionHandler handler,
SessionHandlerOptions handlerOptions) |
Deprecated.
|
void |
IMessageAndSessionPump.registerSessionHandler(ISessionHandler handler,
SessionHandlerOptions handlerOptions,
ExecutorService executorService) |
Receive session messages continuously from the queue.
|
void |
IMessageAndSessionPump.registerSessionHandler(ISessionHandler handler,
ExecutorService executorService) |
Receive session messages continuously from the queue.
|
void |
QueueClient.registerSessionHandler(ISessionHandler handler) |
Deprecated.
|
void |
QueueClient.registerSessionHandler(ISessionHandler handler,
SessionHandlerOptions handlerOptions) |
Deprecated.
|
void |
QueueClient.registerSessionHandler(ISessionHandler handler,
SessionHandlerOptions handlerOptions,
ExecutorService executorService) |
|
void |
QueueClient.registerSessionHandler(ISessionHandler handler,
ExecutorService executorService) |
|
void |
SubscriptionClient.registerSessionHandler(ISessionHandler handler) |
Deprecated.
|
void |
SubscriptionClient.registerSessionHandler(ISessionHandler handler,
SessionHandlerOptions handlerOptions) |
Deprecated.
|
void |
SubscriptionClient.registerSessionHandler(ISessionHandler handler,
SessionHandlerOptions handlerOptions,
ExecutorService executorService) |
|
void |
SubscriptionClient.registerSessionHandler(ISessionHandler handler,
ExecutorService executorService) |
|
void |
ISubscriptionClient.removeRule(String ruleName) |
Removes the rule on the subscription identified by ruleName
|
void |
SubscriptionClient.removeRule(String ruleName) |
|
Instant |
IMessageReceiver.renewMessageLock(IMessage message) |
Renews the lock on the message specified by the lock token.
|
Instant |
IMessageReceiver.renewMessageLock(UUID lockToken) |
Renews the lock on the message specified by the lock token.
|
void |
IMessageSession.renewSessionLock() |
|
void |
MessageSession.renewSessionLock() |
|
void |
TransactionContext.rollback() |
Rollback the transaction
|
long |
IMessageSender.scheduleMessage(IMessage message,
Instant scheduledEnqueueTimeUtc) |
Sends a scheduled message to the Azure Service Bus entity this sender is connected to.
|
long |
IMessageSender.scheduleMessage(IMessage message,
Instant scheduledEnqueueTimeUtc,
TransactionContext transaction) |
Sends a scheduled message to the Azure Service Bus entity this sender is connected to.
|
long |
QueueClient.scheduleMessage(IMessage message,
Instant scheduledEnqueueTimeUtc) |
|
long |
QueueClient.scheduleMessage(IMessage message,
Instant scheduledEnqueueTimeUtc,
TransactionContext transaction) |
|
long |
TopicClient.scheduleMessage(IMessage message,
Instant scheduledEnqueueTimeUtc) |
|
long |
TopicClient.scheduleMessage(IMessage message,
Instant scheduledEnqueueTimeUtc,
TransactionContext transaction) |
|
void |
IMessageSender.send(IMessage message) |
Sends a message to the Azure Service Bus entity this sender is connected to.
|
void |
IMessageSender.send(IMessage message,
TransactionContext transaction) |
Sends a message to the Azure Service Bus entity this sender is connected to.
|
void |
QueueClient.send(IMessage message) |
|
void |
QueueClient.send(IMessage message,
TransactionContext transaction) |
|
void |
TopicClient.send(IMessage message) |
|
void |
TopicClient.send(IMessage message,
TransactionContext transaction) |
|
void |
IMessageSender.sendBatch(Collection<? extends IMessage> messages) |
Sends a batch of messages to the Azure Service Bus entity this sender is connected to.
|
void |
IMessageSender.sendBatch(Collection<? extends IMessage> messages,
TransactionContext transaction) |
Sends a batch of messages to the Azure Service Bus entity this sender is connected to.
|
void |
QueueClient.sendBatch(Collection<? extends IMessage> messages) |
|
void |
QueueClient.sendBatch(Collection<? extends IMessage> messages,
TransactionContext transaction) |
|
void |
TopicClient.sendBatch(Collection<? extends IMessage> messages) |
|
void |
TopicClient.sendBatch(Collection<? extends IMessage> messages,
TransactionContext transaction) |
|
void |
IMessageAndSessionPump.setPrefetchCount(int prefetchCount) |
Set the prefetch count of the receiver.
|
void |
IMessageReceiver.setPrefetchCount(int prefetchCount) |
Set the prefetch count of the receiver.
|
void |
QueueClient.setPrefetchCount(int prefetchCount) |
|
void |
SubscriptionClient.setPrefetchCount(int prefetchCount) |
|
void |
IMessageSession.setState(byte[] state) |
|
void |
MessageSession.setState(byte[] sessionState) |
|