Package com.azure.spring.cloud.autoconfigure.eventhubs

Class AzureEventHubsMessagingAutoConfiguration.ProcessorContainerConfiguration

java.lang.Object

com.azure.spring.cloud.autoconfigure.eventhubs.AzureEventHubsMessagingAutoConfiguration.ProcessorContainerConfiguration

Enclosing class:

AzureEventHubsMessagingAutoConfiguration

@Configuration(proxyBeanMethods=false)
@ConditionalOnBean(com.azure.messaging.eventhubs.CheckpointStore.class)
public static class AzureEventHubsMessagingAutoConfiguration.ProcessorContainerConfiguration
extends Object

Configure the EventHubsProcessorFactory

Constructor Summary

Constructors

Constructor	Description
ProcessorContainerConfiguration()

Method Summary

Modifier and Type	Method	Description
com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory	defaultEventHubsNamespaceProcessorFactory(com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties properties, com.azure.messaging.eventhubs.CheckpointStore checkpointStore, org.springframework.beans.factory.ObjectProvider<com.azure.spring.messaging.PropertiesSupplier<com.azure.spring.messaging.ConsumerIdentifier,com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties>> suppliers)	Creates the default Event Hubs namespace processor factory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProcessorContainerConfiguration

public ProcessorContainerConfiguration()

Method Details

defaultEventHubsNamespaceProcessorFactory

@Bean
@ConditionalOnMissingBean
public com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory defaultEventHubsNamespaceProcessorFactory(com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties properties,
 com.azure.messaging.eventhubs.CheckpointStore checkpointStore,
 org.springframework.beans.factory.ObjectProvider<com.azure.spring.messaging.PropertiesSupplier<com.azure.spring.messaging.ConsumerIdentifier,com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties>> suppliers)

Creates the default Event Hubs namespace processor factory.

Parameters:

properties - Event Hubs namespace related properties.

checkpointStore - Checkpoint store for storing and retrieving partition ownership information and checkpoint details for each partition.

suppliers - Object provider suppliers.

Returns:

A default Event Hubs namespace processor factory.