Package com.azure.spring.messaging.eventhubs.core
package com.azure.spring.messaging.eventhubs.core
Spring Messaging Event Hubs core package.
-
ClassDescriptionThe
EventHubsProcessorFactory
implementation to produce newEventProcessorClient
instances for providedCheckpointStore
checkpointStore
and optionalNamespaceProperties
and processorPropertiesSupplier
on eachDefaultEventHubsNamespaceProcessorFactory.createProcessor(java.lang.String, java.lang.String, com.azure.spring.cloud.service.listener.MessageListener<?>, com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler)
invocation.TheEventHubsProducerFactory
implementation to produce cachedEventHubProducerAsyncClient
instances for providedNamespaceProperties
and optional producerPropertiesSupplier
on eachDefaultEventHubsNamespaceProducerFactory.createProducer(java.lang.String)
invocation.The strategy to produceEventProcessorClient
instance.Called whenever a processor is added or removed.The strategy to produceEventHubProducerAsyncClient
instance.Called whenever a producer is added or removed.A template for executing sending operations asynchronously to Event Hubs.Represents a supplier of partition id or key.