Package com.azure.spring.cloud.autoconfigure.eventhub

Class AzureEventHubAutoConfiguration

java.lang.Object

com.azure.spring.cloud.autoconfigure.eventhub.AzureEventHubAutoConfiguration

@Configuration
@AutoConfigureAfter(com.azure.spring.cloud.autoconfigure.context.AzureContextAutoConfiguration.class)
@ConditionalOnClass(com.azure.messaging.eventhubs.EventHubConsumerAsyncClient.class)
@ConditionalOnProperty(value="spring.cloud.azure.eventhub.enabled",
                       matchIfMissing=true)
@EnableConfigurationProperties(AzureEventHubProperties.class)
public class AzureEventHubAutoConfiguration
extends Object

An auto-configuration for Event Hub, which provides EventHubOperation

Author:

Warren Zhu

Constructor Summary

Constructors

Constructor	Description
AzureEventHubAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
EventHubClientFactory	eventhubClientFactory(EnvironmentProvider environmentProvider, StorageAccountManager storageAccountManager, EventHubConnectionStringProvider eventHubConnectionStringProvider, AzureEventHubProperties properties)
EventHubConnectionStringProvider	eventHubConnectionStringProvider(EventHubNamespaceManager namespaceManager, AzureEventHubProperties properties)	Create a EventHubConnectionStringProvider bean.
EventHubNamespaceManager	eventHubNamespaceManager(com.azure.resourcemanager.AzureResourceManager azureResourceManager, AzureProperties azureProperties)
EventHubOperation	eventHubOperation(EventHubClientFactory clientFactory)
StorageAccountManager	storageAccountManager(com.azure.resourcemanager.AzureResourceManager azureResourceManager, AzureProperties azureProperties)

Methods inherited from class java.lang.Object

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

Constructor Detail

AzureEventHubAutoConfiguration

public AzureEventHubAutoConfiguration()

Method Detail

eventHubNamespaceManager

@Bean
@ConditionalOnMissingBean
@ConditionalOnBean(com.azure.resourcemanager.AzureResourceManager.class)
public EventHubNamespaceManager eventHubNamespaceManager(com.azure.resourcemanager.AzureResourceManager azureResourceManager,
                                                         AzureProperties azureProperties)

storageAccountManager

@Bean
@ConditionalOnMissingBean
@ConditionalOnBean(com.azure.resourcemanager.AzureResourceManager.class)
@ConditionalOnProperty("spring.cloud.azure.eventhub.checkpoint-storage-account")
public StorageAccountManager storageAccountManager(com.azure.resourcemanager.AzureResourceManager azureResourceManager,
                                                   AzureProperties azureProperties)

eventHubConnectionStringProvider

@Bean
@ConditionalOnMissingBean
public EventHubConnectionStringProvider eventHubConnectionStringProvider(@Autowired(required=false)
                                                                         EventHubNamespaceManager namespaceManager,
                                                                         AzureEventHubProperties properties)

Create a EventHubConnectionStringProvider bean. The bean will hold the connection string to the eventhub. If connection-string property is configured in the property files, it will use it. Otherwise, it will try to construct the connection-string using the resource manager.

Parameters:

namespaceManager - The resource manager for Event Hubs namespaces.

properties - The Event Hubs properties.

Returns:

The EventHubConnectionStringProvider bean.

Throws:

IllegalArgumentException - If connection string is empty.

eventhubClientFactory

@Bean
@ConditionalOnMissingBean
public EventHubClientFactory eventhubClientFactory(@Autowired(required=false)
                                                   EnvironmentProvider environmentProvider,
                                                   @Autowired(required=false)
                                                   StorageAccountManager storageAccountManager,
                                                   EventHubConnectionStringProvider eventHubConnectionStringProvider,
                                                   AzureEventHubProperties properties)

eventHubOperation

@Bean
@ConditionalOnMissingBean
public EventHubOperation eventHubOperation(EventHubClientFactory clientFactory)