Package com.alibaba.cloud.stream.binder.rocketmq.properties

Class RocketMQConsumerProperties.Pull

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties.Pull

All Implemented Interfaces:

Serializable

Enclosing class:

RocketMQConsumerProperties

public static class RocketMQConsumerProperties.Pull
extends Object
implements Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Pull()

Method Summary

Modifier and Type	Method	Description
long	getConsumerTimeoutMillisWhenSuspend()
String	getErrAcknowledge()
long	getPollTimeoutMillis()
int	getPullThreadNums()
long	getPullThresholdForAll()
long	getTopicMetadataCheckIntervalMillis()
void	setConsumerTimeoutMillisWhenSuspend(long consumerTimeoutMillisWhenSuspend)
void	setErrAcknowledge(String errAcknowledge)
void	setPollTimeoutMillis(long pollTimeoutMillis)
void	setPullThreadNums(int pullThreadNums)
void	setPullThresholdForAll(long pullThresholdForAll)
void	setTopicMetadataCheckIntervalMillis(long topicMetadataCheckIntervalMillis)

Methods inherited from class java.lang.Object

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

Constructor Details

Pull

public Pull()

Method Details

getPollTimeoutMillis

public long getPollTimeoutMillis()

setPollTimeoutMillis

public void setPollTimeoutMillis(long pollTimeoutMillis)

getPullThreadNums

public int getPullThreadNums()

setPullThreadNums

public void setPullThreadNums(int pullThreadNums)

getTopicMetadataCheckIntervalMillis

public long getTopicMetadataCheckIntervalMillis()

setTopicMetadataCheckIntervalMillis

public void setTopicMetadataCheckIntervalMillis(long topicMetadataCheckIntervalMillis)

getConsumerTimeoutMillisWhenSuspend

public long getConsumerTimeoutMillisWhenSuspend()

setConsumerTimeoutMillisWhenSuspend

public void setConsumerTimeoutMillisWhenSuspend(long consumerTimeoutMillisWhenSuspend)

getErrAcknowledge

public String getErrAcknowledge()

setErrAcknowledge

public void setErrAcknowledge(String errAcknowledge)

getPullThresholdForAll

public long getPullThresholdForAll()

setPullThresholdForAll

public void setPullThresholdForAll(long pullThresholdForAll)