Interface ServiceBusProcessorFactory
- All Known Implementing Classes:
DefaultServiceBusNamespaceProcessorFactory
public interface ServiceBusProcessorFactory
The strategy to produce
ServiceBusProcessorClient
instance.-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic interface
Called whenever a processor is added or removed. -
Method Summary
Modifier and TypeMethodDescriptiondefault void
Add a listener for this factory.com.azure.messaging.servicebus.ServiceBusProcessorClient
createProcessor
(String queue, com.azure.spring.cloud.service.listener.MessageListener<?> messageListener, com.azure.spring.cloud.service.servicebus.consumer.ServiceBusErrorHandler errorHandler) Create aServiceBusProcessorClient
to consume events from the specified queue.com.azure.messaging.servicebus.ServiceBusProcessorClient
createProcessor
(String queue, ServiceBusContainerProperties containerProperties) Create aServiceBusProcessorClient
to consume events from the specified queue.com.azure.messaging.servicebus.ServiceBusProcessorClient
createProcessor
(String topic, String subscription, com.azure.spring.cloud.service.listener.MessageListener<?> messageListener, com.azure.spring.cloud.service.servicebus.consumer.ServiceBusErrorHandler errorHandler) Create aServiceBusProcessorClient
to consume events from the specified topic in the context of the given subscription.com.azure.messaging.servicebus.ServiceBusProcessorClient
createProcessor
(String topic, String subscription, ServiceBusContainerProperties containerProperties) Create aServiceBusProcessorClient
to consume events from the specified topic in the context of the given subscription.default boolean
Remove a listener from the factory.
-
Method Details
-
createProcessor
com.azure.messaging.servicebus.ServiceBusProcessorClient createProcessor(String queue, com.azure.spring.cloud.service.listener.MessageListener<?> messageListener, com.azure.spring.cloud.service.servicebus.consumer.ServiceBusErrorHandler errorHandler) Create aServiceBusProcessorClient
to consume events from the specified queue.- Parameters:
queue
- The queue name.messageListener
- message listener to be registered on service bus processor client.errorHandler
- the error handler to consume the errors.- Returns:
- ServiceBusProcessorClient queue processor client.
-
createProcessor
com.azure.messaging.servicebus.ServiceBusProcessorClient createProcessor(String queue, ServiceBusContainerProperties containerProperties) Create aServiceBusProcessorClient
to consume events from the specified queue.- Parameters:
queue
- The queue name.containerProperties
- theServiceBusContainerProperties
to describe the processor.- Returns:
- the queue processor client.
-
createProcessor
com.azure.messaging.servicebus.ServiceBusProcessorClient createProcessor(String topic, String subscription, com.azure.spring.cloud.service.listener.MessageListener<?> messageListener, com.azure.spring.cloud.service.servicebus.consumer.ServiceBusErrorHandler errorHandler) Create aServiceBusProcessorClient
to consume events from the specified topic in the context of the given subscription.- Parameters:
topic
- The topic.subscription
- The subscription.messageListener
- message listener to be registered on service bus processor client.errorHandler
- the error handler to consume the errors.- Returns:
- the topic processor client.
-
createProcessor
com.azure.messaging.servicebus.ServiceBusProcessorClient createProcessor(String topic, String subscription, ServiceBusContainerProperties containerProperties) Create aServiceBusProcessorClient
to consume events from the specified topic in the context of the given subscription.- Parameters:
topic
- The topic.subscription
- The subscription.containerProperties
- theServiceBusContainerProperties
to describe the processor.- Returns:
- the topic processor client.
-
addListener
Add a listener for this factory.- Parameters:
listener
- the listener.
-
removeListener
Remove a listener from the factory.- Parameters:
listener
- the listener.- Returns:
- true if removed.
-