Package com.azure.spring.messaging.eventhubs.core

Interface EventHubsProducerFactory

All Known Implementing Classes:

DefaultEventHubsNamespaceProducerFactory

public interface EventHubsProducerFactory

The strategy to produce EventHubProducerAsyncClient instance.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	EventHubsProducerFactory.Listener	Called whenever a producer is added or removed.

Method Summary

Modifier and Type	Method	Description
default void	addListener(EventHubsProducerFactory.Listener listener)	Add a listener for this factory.
com.azure.messaging.eventhubs.EventHubProducerAsyncClient	createProducer(String eventHub)	Create EventHubProducerAsyncClient to send events to the event hub.
default boolean	removeListener(EventHubsProducerFactory.Listener listener)	Remove a listener

Method Details

createProducer

com.azure.messaging.eventhubs.EventHubProducerAsyncClient createProducer(String eventHub)

Create EventHubProducerAsyncClient to send events to the event hub.

Parameters:

eventHub - the event hub

Returns:

the producer.

addListener

default void addListener(EventHubsProducerFactory.Listener listener)

Add a listener for this factory.

Parameters:

listener - the listener

removeListener

default boolean removeListener(EventHubsProducerFactory.Listener listener)

Remove a listener

Parameters:

listener - the listener

Returns:

true if removed.