Package com.google.cloud.spring.pubsub.core

Class PubSubConfiguration.Subscriber

java.lang.Object
com.google.cloud.spring.pubsub.core.PubSubConfiguration.Subscriber
Enclosing class:
PubSubConfiguration
public static class PubSubConfiguration.Subscriber extends Object
Subscriber settings.

  • Constructor Details

    • Subscriber

      public Subscriber()

  • Method Details

    • getFullyQualifiedName

      public String getFullyQualifiedName()

    • setFullyQualifiedName

      public void setFullyQualifiedName(String fullyQualifiedName)

    • getRetry

      public PubSubConfiguration.Retry getRetry()

    • getRetryableCodes

      public com.google.api.gax.rpc.StatusCode.Code[] getRetryableCodes()

    • setRetryableCodes

      public void setRetryableCodes(com.google.api.gax.rpc.StatusCode.Code[] retryableCodes)

    • getFlowControl

      public PubSubConfiguration.FlowControl getFlowControl()

    • getPullEndpoint

      public String getPullEndpoint()

    • setPullEndpoint

      public void setPullEndpoint(String pullEndpoint)

    • getMaxAckExtensionPeriod

      public Long getMaxAckExtensionPeriod()

    • setMaxAckExtensionPeriod

      public void setMaxAckExtensionPeriod(Long maxAckExtensionPeriod)

    • getMinDurationPerAckExtension

      public Long getMinDurationPerAckExtension()

    • setMinDurationPerAckExtension

      public void setMinDurationPerAckExtension(Long minDurationPerAckExtension)

    • getMaxDurationPerAckExtension

      public Long getMaxDurationPerAckExtension()

    • setMaxDurationPerAckExtension

      public void setMaxDurationPerAckExtension(Long maxDurationPerAckExtension)

    • getParallelPullCount

      public Integer getParallelPullCount()

    • setParallelPullCount

      public void setParallelPullCount(Integer parallelPullCount)

    • getExecutorThreads

      public Integer getExecutorThreads()

    • setExecutorThreads

      public void setExecutorThreads(int executorThreads)
      Set the number of executor threads.
      Parameters:
      executorThreads - the number of threads

    • getMaxAcknowledgementThreads

      public int getMaxAcknowledgementThreads()

    • setMaxAcknowledgementThreads

      public void setMaxAcknowledgementThreads(int maxAcknowledgementThreads)