All Classes and Interfaces
Class
Description
Checkpoint config to describe different checkpoint strategies.
The offset commit behavior enumeration.
Common properties shared by event hub namespace, a producer, and a consumer.
An event hub consumer related properties.
The
EventHubsProcessorFactory implementation to produce new EventProcessorClient instances
for provided CheckpointStore checkpointStore and optional NamespaceProperties and
processor PropertiesSupplier on each DefaultEventHubsNamespaceProcessorFactory.createProcessor(java.lang.String, java.lang.String, com.azure.spring.cloud.service.listener.MessageListener<?>, com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler) invocation.The
EventHubsProducerFactory implementation to produce cached EventHubProducerAsyncClient instances
for provided NamespaceProperties and optional producer PropertiesSupplier on each
DefaultEventHubsNamespaceProducerFactory.createProducer(java.lang.String) invocation.A converter to turn a
EventBatchContext to
Message and vice versa.The properties to describe an Event Hubs listener container.
Azure Event Hubs internal headers for Spring Messaging messages.
A converter to turn a
Message to EventData and vice versa.EventHubs message listener container using
EventProcessorClient to subscribe to event hubs and consume events
from all the partitions of each event hub.The strategy to produce
EventProcessorClient instance.Called whenever a processor is added or removed.
The strategy to produce
EventHubProducerAsyncClient instance.Called whenever a producer is added or removed.
A template for executing sending operations asynchronously to Event Hubs.
An event hub namespace related properties.
Represents a supplier of partition id or key.
An event hub processor related properties.
An event hub producer related properties.