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()
Long	getMaxAckExtensionPeriod()
int	getMaxAcknowledgementThreads()
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	setMaxAckExtensionPeriod(Long maxAckExtensionPeriod)
void	setMaxAcknowledgementThreads(int maxAcknowledgementThreads)
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

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)

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)