Package | Description |
---|---|
com.azure.messaging.servicebus |
Package containing classes for creating
ServiceBusSenderAsyncClient ,
ServiceBusProcessorClient , and
ServiceBusReceiverAsyncClient to perform operations on Azure Service Bus. |
Modifier and Type | Method and Description |
---|---|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.disableAutoComplete()
Disables auto-complete and auto-abandon of received messages.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)
Sets the amount of time to continue auto-renewing the lock.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.maxConcurrentCalls(int maxConcurrentCalls)
Max concurrent messages that this processor should process.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.maxConcurrentSessions(int maxConcurrentSessions)
Enables session processing roll-over by processing at most
maxConcurrentSessions . |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.prefetchCount(int prefetchCount)
Sets the prefetch count of the processor.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.processError(Consumer<ServiceBusErrorContext> processError)
The error handler for the processor which will be invoked in the event of an error while receiving messages.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.processMessage(Consumer<ServiceBusReceivedMessageContext> processMessage)
The message processing callback for the processor that will be executed when a message is received.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.queueName(String queueName)
Sets the name of the queue to create a processor for.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.receiveMode(ServiceBusReceiveMode receiveMode)
Sets the receive mode for the processor.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.sessionProcessor()
A new instance of
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder used to configure a Service Bus processor
instance that processes sessions. |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.subscriptionName(String subscriptionName)
Sets the name of the subscription in the topic to listen to.
|
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder |
ServiceBusClientBuilder.ServiceBusSessionProcessorClientBuilder.topicName(String topicName)
Sets the name of the topic.
|
Copyright © 2021 Microsoft Corporation. All rights reserved.