Package com.azure.spring.messaging.servicebus.core

Interface ServiceBusConsumerFactory

All Known Implementing Classes:

DefaultServiceBusNamespaceConsumerFactory

public interface ServiceBusConsumerFactory

The strategy to produce ServiceBusSessionReceiverClient instance.

Since:

5.22.0

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ServiceBusConsumerFactory.Listener	Called whenever a consumer (session receiver client) is added or removed.

Method Summary

Modifier and Type	Method	Description
default void	addListener(ServiceBusConsumerFactory.Listener listener)	Add a listener for this factory.
com.azure.messaging.servicebus.ServiceBusSessionReceiverClient	createReceiver(String name)	Create a ServiceBusSessionReceiverClient to consume events from the specified queue.
com.azure.messaging.servicebus.ServiceBusSessionReceiverClient	createReceiver(String name, com.azure.spring.cloud.service.servicebus.properties.ServiceBusEntityType entityType)	Create a ServiceBusSessionReceiverClient to consume events from the specified queue.
default boolean	removeListener(ServiceBusConsumerFactory.Listener listener)	Remove a listener from the factory.

Method Details

createReceiver

com.azure.messaging.servicebus.ServiceBusSessionReceiverClient createReceiver(String name)

Create a ServiceBusSessionReceiverClient to consume events from the specified queue.

Parameters:

name - the destination entity name.

Returns:

ServiceBusReceiverClient queue receiver client.

createReceiver

com.azure.messaging.servicebus.ServiceBusSessionReceiverClient createReceiver(String name,
 com.azure.spring.cloud.service.servicebus.properties.ServiceBusEntityType entityType)

Create a ServiceBusSessionReceiverClient to consume events from the specified queue.

Parameters:

name - the destination entity name.

entityType - the Service Bus entity type.

Returns:

ServiceBusReceiverClient queue receiver client.

addListener

default void addListener(ServiceBusConsumerFactory.Listener listener)

Add a listener for this factory.

Parameters:

listener - the listener.

removeListener

default boolean removeListener(ServiceBusConsumerFactory.Listener listener)

Remove a listener from the factory.

Parameters:

listener - the listener.

Returns:

true if removed.