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 ProcessorProperties

    getBatch, getInitialPartitionEventPosition, getLoadBalancing, getTrackLastEnqueuedEventProperties, setTrackLastEnqueuedEventProperties

    Methods inherited from class ConsumerProperties

    getConsumerGroup, getPrefetchCount, setConsumerGroup, setPrefetchCount

    Methods inherited from class 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 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

  • 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.