public static class GcpPubSubProperties.Subscriber extends Object
Constructor and Description |
---|
Subscriber() |
Modifier and Type | Method and Description |
---|---|
int |
getExecutorThreads() |
GcpPubSubProperties.FlowControl |
getFlowControl() |
Long |
getMaxAckExtensionPeriod() |
int |
getMaxAcknowledgementThreads() |
Integer |
getParallelPullCount() |
String |
getPullEndpoint() |
GcpPubSubProperties.Retry |
getRetry() |
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) |
public GcpPubSubProperties.Retry getRetry()
public GcpPubSubProperties.FlowControl getFlowControl()
public String getPullEndpoint()
public void setPullEndpoint(String pullEndpoint)
public Long getMaxAckExtensionPeriod()
public void setMaxAckExtensionPeriod(Long maxAckExtensionPeriod)
public Integer getParallelPullCount()
public void setParallelPullCount(Integer parallelPullCount)
public int getExecutorThreads()
public void setExecutorThreads(int executorThreads)
executorThreads
- the number of threadspublic int getMaxAcknowledgementThreads()
public void setMaxAcknowledgementThreads(int maxAcknowledgementThreads)
Copyright © 2021. All rights reserved.