Package io.micronaut.gcp.pubsub.configuration

Class PubSubConfigurationProperties

java.lang.Object
io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
@ConfigurationProperties("gcp.pubsub") public class PubSubConfigurationProperties extends Object
Configuration properties for PubSub support.
Since:
2.0.0
Author:
Vinicius Carvalho

  • Field Details

  • Constructor Details

    • PubSubConfigurationProperties

      public PubSubConfigurationProperties()

  • Method Details

    • getPublishingExecutor

      public String getPublishingExecutor()
      The name of the ScheduledExecutorService to be used by all Publisher instances. Defaults to "scheduled".
      Returns:
      the name of the publishing executor

    • setPublishingExecutor

      public void setPublishingExecutor(String publishingExecutor)
      Parameters:
      publishingExecutor - Name of the ScheduledExecutorService to be used by all Publisher instances. Default: "scheduled"

    • getSubscribingExecutor

      public String getSubscribingExecutor()
      The name of the ScheduledExecutorService to be used by all Subscriber instances. Defaults to "scheduled".
      Returns:
      the name of the subscribing executor

    • setSubscribingExecutor

      public void setSubscribingExecutor(String subscribingExecutor)
      Parameters:
      subscribingExecutor - Name of the ScheduledExecutorService to be used by all Subscriber instances. Default: "scheduled"

    • getKeepAliveIntervalMinutes

      public int getKeepAliveIntervalMinutes()
      How often to ping the server to keep the channel alive. Defaults to 5 minutes.
      Returns:
      interval

    • setKeepAliveIntervalMinutes

      public void setKeepAliveIntervalMinutes(int keepAliveIntervalMinutes)
      How often to ping the server to keep the channel alive. Default: 5 minutes.
      Parameters:
      keepAliveIntervalMinutes -

    • getTopicEndpoint

      public String getTopicEndpoint()
      Which endpoint the Publisher should publish messages to. Defaults to the global endpoint
      Returns:
      endpoint

    • setTopicEndpoint

      public void setTopicEndpoint(String topicEndpoint)
      Parameters:
      topicEndpoint - to be used by all Publisher instances. Default: "" (i.e. the global endpoint)

    • isNackOnShutdown

      public boolean isNackOnShutdown()
      Whether subscribers should stop processing pending in-memory messages and eagerly nack() during application shutdown. Defaults to false.
      Returns:
      nack on shutdown configuration
      Since:
      5.2.0

    • setNackOnShutdown

      public void setNackOnShutdown(boolean nackOnShutdown)
      Parameters:
      nackOnShutdown - whether subscribers should stop processing pending in-memory messages and eagerly nack() during application shutdown.
      Since:
      5.2.0