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()
     

  • 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()

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