Package io.micronaut.gcp.pubsub.configuration

Class PublisherConfigurationProperties

  • @EachProperty("gcp.pubsub.publisher")
public class PublisherConfigurationProperties
extends java.lang.Object
    Configuration properties for PubSub Publishers. Each topic has its own configuration if set by the user. for example gcp.pubsub.publisher.animals and gcp.pubsub.publisher.cars would define publishers with different configurations for each topic.
    Since:
    2.0.0
    Author:
    Vinicius Carvalho, James Kleeh

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      com.google.api.gax.batching.BatchingSettings.Builder getBatchingSettings()
      Controls message publishing batch.
      java.lang.String getExecutor()  
      com.google.api.gax.batching.FlowControlSettings.Builder getFlowControlSettings()
      Flow Control settings.
      java.lang.String getName()  
      com.google.api.gax.retrying.RetrySettings.Builder getRetrySettings()
      Retry policies.
      void setBatchingSettings​(com.google.api.gax.batching.BatchingSettings.Builder batchingSettings)
      Controls message publishing batch.
      void setExecutor​(java.lang.String executor)  
      void setFlowControlSettings​(com.google.api.gax.batching.FlowControlSettings.Builder flowControlSettings)
      Flow Control settings.
      void setRetrySettings​(com.google.api.gax.retrying.RetrySettings.Builder retrySettings)
      Retry policies.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • PublisherConfigurationProperties

        public PublisherConfigurationProperties​(@Parameter
                                        java.lang.String name)

    • Method Detail

      • getRetrySettings

        public com.google.api.gax.retrying.RetrySettings.Builder getRetrySettings()
        Retry policies.
        Returns:
        the retry settings

      • setRetrySettings

        public void setRetrySettings​(com.google.api.gax.retrying.RetrySettings.Builder retrySettings)
        Retry policies.
        Parameters:
        retrySettings - retry settings

      • getBatchingSettings

        public com.google.api.gax.batching.BatchingSettings.Builder getBatchingSettings()
        Controls message publishing batch.
        Returns:
        batchSettings

      • setBatchingSettings

        public void setBatchingSettings​(com.google.api.gax.batching.BatchingSettings.Builder batchingSettings)
        Controls message publishing batch.
        Parameters:
        batchingSettings - batchingSettings

      • 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

      • getName

        public java.lang.String getName()
        Returns:
        the name of this configuration

      • getExecutor

        public java.lang.String getExecutor()
        Returns:
        executor name

      • setExecutor

        public void setExecutor​(java.lang.String executor)
        Parameters:
        executor - name to be set