Package com.azure.spring.messaging.eventhubs.core
package com.azure.spring.messaging.eventhubs.core
Spring Messaging Event Hubs core package.
-
ClassDescriptionThe
EventHubsProcessorFactoryimplementation to produce newEventProcessorClientinstances for providedCheckpointStorecheckpointStoreand optionalNamespacePropertiesand processorPropertiesSupplieron eachDefaultEventHubsNamespaceProcessorFactory.createProcessor(java.lang.String, java.lang.String, com.azure.spring.cloud.service.listener.MessageListener<?>, com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler)invocation.TheEventHubsProducerFactoryimplementation to produce cachedEventHubProducerAsyncClientinstances for providedNamespacePropertiesand optional producerPropertiesSupplieron eachDefaultEventHubsNamespaceProducerFactory.createProducer(java.lang.String)invocation.The strategy to produceEventProcessorClientinstance.Called whenever a processor is added or removed.The strategy to produceEventHubProducerAsyncClientinstance.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.