IQueueClient Interface
public interface IQueueClient extends IMessageSender,IMessageEntityClient
QueueClient can be used for all basic interactions with a Service Bus Queue.
Method Summary
Modifier and Type | Method and Description |
---|---|
String |
getQueueName()
Gets the name of the queue. |
Receive |
getReceiveMode()
Gets the ReceiveMode of the current receiver |
Inherited Members
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandon(UUID)
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandon(UUID,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandon(UUID,Map<String, Object>)
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandon(UUID,Map<String, Object>,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandonAsync(UUID)
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandonAsync(UUID,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandonAsync(UUID,Map<String, Object>)
com.microsoft.azure.servicebus.IMessageAndSessionPump.abandonAsync(UUID,Map<String, Object>,TransactionContext)
IMessageSender.cancelScheduledMessage(long sequenceNumber)
IMessageSender.cancelScheduledMessageAsync(long sequenceNumber)
ICloseable.close()
ICloseable.closeAsync()
com.microsoft.azure.servicebus.IMessageAndSessionPump.complete(UUID)
com.microsoft.azure.servicebus.IMessageAndSessionPump.complete(UUID,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.completeAsync(UUID)
com.microsoft.azure.servicebus.IMessageAndSessionPump.completeAsync(UUID,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID,Map<String, Object>)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID,Map<String, Object>,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID,String,String)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID,String,String,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID,String,String,Map<String, Object>)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetter(UUID,String,String,Map<String, Object>,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID,Map<String, Object>)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID,Map<String, Object>,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID,String,String)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID,String,String,TransactionContext)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID,String,String,Map<String, Object>)
com.microsoft.azure.servicebus.IMessageAndSessionPump.deadLetterAsync(UUID,String,String,Map<String, Object>,TransactionContext)
IMessageEntityClient.getEntityPath()
IMessageAndSessionPump.getPrefetchCount()
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerMessageHandler(IMessageHandler)
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerMessageHandler(IMessageHandler,ExecutorService)
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerMessageHandler(IMessageHandler,MessageHandlerOptions)
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerMessageHandler(IMessageHandler,MessageHandlerOptions,ExecutorService)
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerSessionHandler(ISessionHandler)
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerSessionHandler(ISessionHandler,ExecutorService)
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerSessionHandler(ISessionHandler,SessionHandlerOptions)
com.microsoft.azure.servicebus.IMessageAndSessionPump.registerSessionHandler(ISessionHandler,SessionHandlerOptions,ExecutorService)
IMessageSender.scheduleMessage(IMessage message, Instant scheduledEnqueueTimeUtc)
IMessageSender.scheduleMessage(IMessage message, Instant scheduledEnqueueTimeUtc, TransactionContext transaction)
IMessageSender.scheduleMessageAsync(IMessage message, Instant scheduledEnqueueTimeUtc)
IMessageSender.scheduleMessageAsync(IMessage message, Instant scheduledEnqueueTimeUtc, TransactionContext transaction)
IMessageSender.send(IMessage message)
IMessageSender.send(IMessage message, TransactionContext transaction)
IMessageSender.sendAsync(IMessage message)
IMessageSender.sendAsync(IMessage message, TransactionContext transaction)
IMessageSender.sendBatch(Collection<? extends IMessage> messages)
IMessageSender.sendBatch(Collection<? extends IMessage> messages, TransactionContext transaction)
IMessageSender.sendBatchAsync(Collection<? extends IMessage> messages)
IMessageSender.sendBatchAsync(Collection<? extends IMessage> messages, TransactionContext transaction)
IMessageAndSessionPump.setPrefetchCount(int prefetchCount)
Method Details
getQueueName
public String getQueueName()
Gets the name of the queue.
Returns:
The name of the queue.
getReceiveMode
public ReceiveMode getReceiveMode()
Gets the ReceiveMode of the current receiver
Returns:
The receive mode.
Applies to
Collaborate with us on GitHub
The source for this content can be found on GitHub, where you can also create and review issues and pull requests. For more information, see our contributor guide.
Azure SDK for Java