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

Class AzureBlobCheckpointStoreConfiguration

java.lang.Object

com.azure.spring.cloud.autoconfigure.eventhubs.AzureBlobCheckpointStoreConfiguration

@Configuration(proxyBeanMethods=false)
@ConditionalOnClass({com.azure.messaging.eventhubs.checkpointstore.blob.BlobCheckpointStore.class,com.azure.messaging.eventhubs.EventHubClientBuilder.class})
@ConditionalOnProperty(prefix="spring.cloud.azure.eventhubs.processor.checkpoint-store",
                       name={"container-name","account-name"})
public class AzureBlobCheckpointStoreConfiguration
extends Object

Configures a BlobCheckpointStore

Constructor Summary

Constructors

Constructor	Description
AzureBlobCheckpointStoreConfiguration()

Method Summary

Modifier and Type	Method	Description
BlobCheckpointStoreContainerInitializer	blobCheckpointStoreContainerCreationInitializer()	The default BlobCheckpointStoreContainerInitializer to create the storage blob if not exists.

Methods inherited from class java.lang.Object

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

Constructor Details

AzureBlobCheckpointStoreConfiguration

public AzureBlobCheckpointStoreConfiguration()

Method Details

blobCheckpointStoreContainerCreationInitializer

@Bean
@ConditionalOnProperty(value="spring.cloud.azure.eventhubs.processor.checkpoint-store.create-container-if-not-exists",
                       havingValue="true")
public BlobCheckpointStoreContainerInitializer blobCheckpointStoreContainerCreationInitializer()

The default BlobCheckpointStoreContainerInitializer to create the storage blob if not exists.

Returns:

the default BlobCheckpointStoreContainerInitializer.