Package io.micronaut.gcp.pubsub.configuration

Class SubscriberConfigurationProperties

java.lang.Object
io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
@EachProperty("gcp.pubsub.subscriber") public class SubscriberConfigurationProperties extends Object
Configuration properties for PubSub Subscriber. Each topic has its own configuration if set by the user. for example gcp.pubsub.publisher.animals and gcp.pubsub.publisher.cars would define subscribers with different configurations for each Subscription.
Since:
2.0.0
Author:
Vinicius Carvalho

  • Constructor Details

    • SubscriberConfigurationProperties

      public SubscriberConfigurationProperties(@Parameter String name)
      Parameters:
      name - of this configuration.

  • Method Details

    • getParallelPullCount

      public Integer getParallelPullCount()
      Returns:
      number of concurrent pulls

    • setParallelPullCount

      public void setParallelPullCount(Integer parallelPullCount)
      Parameters:
      parallelPullCount - number of concurrent pulls

    • getMaxAckExtensionPeriod

      public org.threeten.bp.Duration getMaxAckExtensionPeriod()
      Set the maximum period a message ack deadline will be extended. Defaults to one hour.
      Returns:
      max ack deadline.

    • setMaxAckExtensionPeriod

      public void setMaxAckExtensionPeriod(org.threeten.bp.Duration maxAckExtensionPeriod)
      Set the maximum period a message ack deadline will be extended. Defaults to one hour.
      Parameters:
      maxAckExtensionPeriod - value

    • getMaxDurationPerAckExtension

      public org.threeten.bp.Duration getMaxDurationPerAckExtension()
      Returns:
      the maxDurationPerAckExtension

    • setMaxDurationPerAckExtension

      public void setMaxDurationPerAckExtension(org.threeten.bp.Duration maxDurationPerAckExtension)
      Set the upper bound for a single mod ack extention period.

      The ack deadline will continue to be extended by up to this duration until MaxAckExtensionPeriod is reached. Setting MaxDurationPerAckExtension bounds the maximum amount of time before a mesage re-delivery in the event the Subscriber fails to extend the deadline.

      MaxDurationPerAckExtension configuration can be disabled by specifying a zero duration.

      Parameters:
      maxDurationPerAckExtension - value

    • getName

      public String getName()
      Returns:
      the name of the configuration

    • getExecutor

      public String getExecutor()
      Returns:
      executor name

    • setExecutor

      public void setExecutor(String executor)
      Parameters:
      executor - name to be set

    • getFlowControlSettings

      public com.google.api.gax.batching.FlowControlSettings.Builder getFlowControlSettings()
      Flow Control settings.
      Returns:
      flowControlSettings

    • setFlowControlSettings

      public void setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings.Builder flowControlSettings)
      Flow Control settings.
      Parameters:
      flowControlSettings - flow control settings