Package com.azure.spring.messaging.eventhubs.core.properties

Class EventHubsContainerProperties

java.lang.Object

com.azure.spring.cloud.core.implementation.properties.AzureSdkProperties

com.azure.spring.cloud.core.implementation.properties.AzureAmqpSdkProperties

com.azure.spring.messaging.eventhubs.core.properties.CommonProperties

com.azure.spring.messaging.eventhubs.core.properties.ConsumerProperties

com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties

com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties

All Implemented Interfaces:

com.azure.spring.cloud.core.properties.AzureProperties, com.azure.spring.cloud.core.provider.authentication.TokenCredentialOptionsProvider, com.azure.spring.cloud.core.provider.AzureProfileOptionsProvider, com.azure.spring.cloud.core.provider.ClientOptionsProvider, com.azure.spring.cloud.core.provider.connectionstring.ConnectionStringProvider, com.azure.spring.cloud.core.provider.ProxyOptionsProvider, com.azure.spring.cloud.core.provider.RetryOptionsProvider, com.azure.spring.cloud.service.implementation.eventhubs.properties.EventHubClientCommonProperties, com.azure.spring.cloud.service.implementation.eventhubs.properties.EventHubConsumerProperties, com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties

public class EventHubsContainerProperties
extends ProcessorProperties

The properties to describe an Event Hubs listener container.

Nested Class Summary

Nested classes/interfaces inherited from interface com.azure.spring.cloud.core.provider.AzureProfileOptionsProvider

com.azure.spring.cloud.core.provider.AzureProfileOptionsProvider.AzureEnvironmentOptions, com.azure.spring.cloud.core.provider.AzureProfileOptionsProvider.CloudType, com.azure.spring.cloud.core.provider.AzureProfileOptionsProvider.ProfileOptions

Nested classes/interfaces inherited from interface com.azure.spring.cloud.core.provider.ClientOptionsProvider

com.azure.spring.cloud.core.provider.ClientOptionsProvider.AmqpClientOptions, com.azure.spring.cloud.core.provider.ClientOptionsProvider.ClientOptions, com.azure.spring.cloud.core.provider.ClientOptionsProvider.HttpClientOptions

Nested classes/interfaces inherited from interface com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties

com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.EventBatch, com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing, com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition

Nested classes/interfaces inherited from interface com.azure.spring.cloud.core.provider.ProxyOptionsProvider

com.azure.spring.cloud.core.provider.ProxyOptionsProvider.AmqpProxyOptions, com.azure.spring.cloud.core.provider.ProxyOptionsProvider.HttpProxyOptions, com.azure.spring.cloud.core.provider.ProxyOptionsProvider.ProxyOptions

Nested classes/interfaces inherited from interface com.azure.spring.cloud.core.provider.RetryOptionsProvider

com.azure.spring.cloud.core.provider.RetryOptionsProvider.AmqpRetryOptions, com.azure.spring.cloud.core.provider.RetryOptionsProvider.RetryMode, com.azure.spring.cloud.core.provider.RetryOptionsProvider.RetryOptions

Nested classes/interfaces inherited from interface com.azure.spring.cloud.core.provider.authentication.TokenCredentialOptionsProvider

com.azure.spring.cloud.core.provider.authentication.TokenCredentialOptionsProvider.TokenCredentialOptions

Constructor Summary

Constructors

Constructor	Description
EventHubsContainerProperties()	Creates an instance of EventHubsContainerProperties.

Method Summary

Modifier and Type	Method	Description
CheckpointConfig	getCheckpointConfig()	Get the checkpoint config.
Consumer<com.azure.messaging.eventhubs.models.CloseContext>	getCloseContextConsumer()	Get the consumer to consume close context.
com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler	getErrorHandler()	Get the error handler of the container.
Consumer<com.azure.messaging.eventhubs.models.InitializationContext>	getInitializationContextConsumer()	Get the consumer to consume initialization context.
com.azure.spring.cloud.service.listener.MessageListener<?>	getMessageListener()	Get the message listener of the container.
void	setCheckpointConfig(CheckpointConfig checkpointConfig)	Set the checkpoint config.
void	setCloseContextConsumer(Consumer<com.azure.messaging.eventhubs.models.CloseContext> closeContextConsumer)	Set the consumer to consume close context.
void	setErrorHandler(com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler errorHandler)	Set the error handler for the container.
void	setInitializationContextConsumer(Consumer<com.azure.messaging.eventhubs.models.InitializationContext> initializationContextConsumer)	Set the consumer to consume initialization context.
void	setMessageListener(com.azure.spring.cloud.service.listener.MessageListener<?> messageListener)	Set the message listener for the container.

Methods inherited from class com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties

getBatch, getInitialPartitionEventPosition, getLoadBalancing, getTrackLastEnqueuedEventProperties, setTrackLastEnqueuedEventProperties

Methods inherited from class com.azure.spring.messaging.eventhubs.core.properties.ConsumerProperties

getConsumerGroup, getPrefetchCount, setConsumerGroup, setPrefetchCount

Methods inherited from class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties

getConnectionString, getCustomEndpointAddress, getDomainName, getEventHubName, getFullyQualifiedNamespace, getNamespace, setConnectionString, setCustomEndpointAddress, setDomainName, setEventHubName, setNamespace

Methods inherited from class com.azure.spring.cloud.core.implementation.properties.AzureAmqpSdkProperties

getClient, getProxy, getRetry

Methods inherited from class com.azure.spring.cloud.core.implementation.properties.AzureSdkProperties

getCredential, getProfile

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.azure.spring.cloud.core.provider.AzureProfileOptionsProvider

getProfile

Methods inherited from interface com.azure.spring.cloud.core.provider.ClientOptionsProvider

getClient

Methods inherited from interface com.azure.spring.cloud.core.provider.connectionstring.ConnectionStringProvider

getConnectionString

Methods inherited from interface com.azure.spring.cloud.service.implementation.eventhubs.properties.EventHubClientCommonProperties

getCustomEndpointAddress, getDomainName, getEventHubName, getFullyQualifiedNamespace, getNamespace

Methods inherited from interface com.azure.spring.cloud.service.implementation.eventhubs.properties.EventHubConsumerProperties

getConsumerGroup, getPrefetchCount

Methods inherited from interface com.azure.spring.cloud.core.provider.ProxyOptionsProvider

getProxy

Methods inherited from interface com.azure.spring.cloud.core.provider.RetryOptionsProvider

getRetry

Methods inherited from interface com.azure.spring.cloud.core.provider.authentication.TokenCredentialOptionsProvider

getCredential

Constructor Details

EventHubsContainerProperties

public EventHubsContainerProperties()

Creates an instance of EventHubsContainerProperties.

Method Details

getMessageListener

public com.azure.spring.cloud.service.listener.MessageListener<?> getMessageListener()

Get the message listener of the container.

Returns:

the message listener of the container.

setMessageListener

public void setMessageListener(com.azure.spring.cloud.service.listener.MessageListener<?> messageListener)

Set the message listener for the container.

Parameters:

messageListener - the message listener.

getErrorHandler

public com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler getErrorHandler()

Get the error handler of the container.

Returns:

the error handler of the container.

setErrorHandler

public void setErrorHandler(com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler errorHandler)

Set the error handler for the container.

Parameters:

errorHandler - the error handler.

getInitializationContextConsumer

public Consumer<com.azure.messaging.eventhubs.models.InitializationContext> getInitializationContextConsumer()

Get the consumer to consume initialization context.

Returns:

the consumer to consume initialization context.

setInitializationContextConsumer

public void setInitializationContextConsumer(Consumer<com.azure.messaging.eventhubs.models.InitializationContext> initializationContextConsumer)

Set the consumer to consume initialization context.

Parameters:

initializationContextConsumer - the consumer to consume initialization context.

getCloseContextConsumer

public Consumer<com.azure.messaging.eventhubs.models.CloseContext> getCloseContextConsumer()

Get the consumer to consume close context.

Returns:

the consumer to consume close context.

setCloseContextConsumer

public void setCloseContextConsumer(Consumer<com.azure.messaging.eventhubs.models.CloseContext> closeContextConsumer)

Set the consumer to consume close context.

Parameters:

closeContextConsumer - the consumer to consume close context.

getCheckpointConfig

public CheckpointConfig getCheckpointConfig()

Get the checkpoint config.

Returns:

the checkpoint config.

setCheckpointConfig

public void setCheckpointConfig(CheckpointConfig checkpointConfig)

Set the checkpoint config.

Parameters:

checkpointConfig - the checkpoint config.