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 Summary

Constructors

Constructor and Description
Subscriber()

Method Summary

Modifier and Type	Method and Description
Integer	getExecutorThreads()
PubSubConfiguration.FlowControl	getFlowControl()
String	getFullyQualifiedName()
Long	getMaxAckExtensionPeriod()
int	getMaxAcknowledgementThreads()
Long	getMaxDurationPerAckExtension()
Long	getMinDurationPerAckExtension()
Integer	getParallelPullCount()
String	getPullEndpoint()
PubSubConfiguration.Retry	getRetry()
com.google.api.gax.rpc.StatusCode.Code[]	getRetryableCodes()
void	setExecutorThreads(int executorThreads) Set the number of executor threads.
void	setFullyQualifiedName(String fullyQualifiedName)
void	setMaxAckExtensionPeriod(Long maxAckExtensionPeriod)
void	setMaxAcknowledgementThreads(int maxAcknowledgementThreads)
void	setMaxDurationPerAckExtension(Long maxDurationPerAckExtension)
void	setMinDurationPerAckExtension(Long minDurationPerAckExtension)
void	setParallelPullCount(Integer parallelPullCount)
void	setPullEndpoint(String pullEndpoint)
void	setRetryableCodes(com.google.api.gax.rpc.StatusCode.Code[] retryableCodes)

Methods inherited from class java.lang.Object

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

Constructor Detail

Subscriber

public Subscriber()

Method Detail

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)