Package com.azure.spring.cloud.stream.binder.eventhubs.config

Class EventHubsBinderConfiguration

java.lang.Object

com.azure.spring.cloud.stream.binder.eventhubs.config.EventHubsBinderConfiguration

@Configuration(proxyBeanMethods=false)
@ConditionalOnMissingBean(org.springframework.cloud.stream.binder.Binder.class)
@Import({com.azure.spring.cloud.autoconfigure.context.AzureGlobalPropertiesAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.context.AzureTokenCredentialAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.resourcemanager.AzureResourceManagerAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.resourcemanager.AzureEventHubsResourceManagerAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.eventhubs.AzureEventHubsAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.eventhubs.AzureEventHubsMessagingAutoConfiguration.class,com.azure.spring.cloud.stream.binder.eventhubs.config.EventHubsBinderHealthIndicatorConfiguration.class})
@EnableConfigurationProperties(com.azure.spring.cloud.stream.binder.eventhubs.core.properties.EventHubsExtendedBindingProperties.class)
public class EventHubsBinderConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
EventHubsBinderConfiguration()

Method Summary

Modifier and Type	Method	Description
EventHubsMessageChannelBinder	eventHubBinder(EventHubsChannelProvisioner channelProvisioner, EventHubsExtendedBindingProperties bindingProperties, org.springframework.beans.factory.ObjectProvider<com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties> namespaceProperties, org.springframework.beans.factory.ObjectProvider<com.azure.messaging.eventhubs.CheckpointStore> checkpointStores, org.springframework.beans.factory.ObjectProvider<EventHubsProducerFactoryCustomizer> producerFactoryCustomizers, org.springframework.beans.factory.ObjectProvider<EventHubsProcessorFactoryCustomizer> processorFactoryCustomizers)	Declare the EventHubsMessageChannelBinder bean.
EventHubsChannelProvisioner	eventHubChannelProvisioner()	Declare the EventHubsChannelProvisioner bean.

Methods inherited from class java.lang.Object

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

Constructor Details

EventHubsBinderConfiguration

public EventHubsBinderConfiguration()

Method Details

eventHubChannelProvisioner

@Bean
@ConditionalOnMissingBean({com.azure.spring.cloud.resourcemanager.provisioning.EventHubsProvisioner.class,com.azure.spring.cloud.stream.binder.eventhubs.core.provisioning.EventHubsChannelProvisioner.class})
public EventHubsChannelProvisioner eventHubChannelProvisioner()

Declare the EventHubsChannelProvisioner bean.

Returns:

the EventHubsChannelProvisioner bean.

eventHubBinder

@Bean
@ConditionalOnMissingBean
public EventHubsMessageChannelBinder eventHubBinder(EventHubsChannelProvisioner channelProvisioner,
 EventHubsExtendedBindingProperties bindingProperties,
 org.springframework.beans.factory.ObjectProvider<com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties> namespaceProperties,
 org.springframework.beans.factory.ObjectProvider<com.azure.messaging.eventhubs.CheckpointStore> checkpointStores,
 org.springframework.beans.factory.ObjectProvider<EventHubsProducerFactoryCustomizer> producerFactoryCustomizers,
 org.springframework.beans.factory.ObjectProvider<EventHubsProcessorFactoryCustomizer> processorFactoryCustomizers)

Declare the EventHubsMessageChannelBinder bean.

Parameters:

channelProvisioner - the channel provisioner.

bindingProperties - the binding properties.

namespaceProperties - the namespace properties.

checkpointStores - the checkpoint stores.

producerFactoryCustomizers - customizers to customize producer factories.

processorFactoryCustomizers - customizers to customize processor factories.

Returns:

the EventHubsMessageChannelBinder bean.