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

Class RocketMQConsumerProperties

java.lang.Object

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

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

All Implemented Interfaces:

Serializable

public class RocketMQConsumerProperties
extends RocketMQCommonProperties

Extended consumer properties for RocketMQ binder.

Author:

Jim

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RocketMQConsumerProperties.Pull
static class	RocketMQConsumerProperties.Push

Constructor Summary

Constructors

Constructor	Description
RocketMQConsumerProperties()

Method Summary

Modifier and Type	Method	Description
String	getAllocateMessageQueueStrategy()
org.apache.rocketmq.common.consumer.ConsumeFromWhere	getConsumeFromWhere()
int	getConsumeMaxSpan()
String	getConsumeTimestamp()
String	getMessageModel()
RocketMQConsumerProperties.Pull	getPull()
int	getPullBatchSize()
int	getPullThresholdForQueue()
int	getPullThresholdSizeForQueue()
long	getPullTimeDelayMillsWhenException()
RocketMQConsumerProperties.Push	getPush()
String	getSubscription()
void	setAllocateMessageQueueStrategy(String allocateMessageQueueStrategy)
RocketMQConsumerProperties	setConsumeFromWhere(org.apache.rocketmq.common.consumer.ConsumeFromWhere consumeFromWhere)
RocketMQConsumerProperties	setConsumeMaxSpan(int consumeMaxSpan)
RocketMQConsumerProperties	setConsumeTimestamp(String consumeTimestamp)
RocketMQConsumerProperties	setMessageModel(String messageModel)
RocketMQConsumerProperties	setPull(RocketMQConsumerProperties.Pull pull)
RocketMQConsumerProperties	setPullBatchSize(int pullBatchSize)
RocketMQConsumerProperties	setPullThresholdForQueue(int pullThresholdForQueue)
RocketMQConsumerProperties	setPullThresholdSizeForQueue(int pullThresholdSizeForQueue)
RocketMQConsumerProperties	setPullTimeDelayMillsWhenException(long pullTimeDelayMillsWhenException)
void	setPush(RocketMQConsumerProperties.Push push)
void	setSubscription(String subscription)

Methods inherited from class com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQCommonProperties

getAccessChannel, getAccessKey, getCustomizedTraceTopic, getEnabled, getEnableMsgTrace, getGroup, getHeartbeatBrokerInterval, getNameServer, getNamespace, getNamespaceV2, getPersistConsumerOffsetInterval, getPollNameServerInterval, getSecretKey, getUnitName, getUseTLS, getVipChannelEnabled, setAccessChannel, setAccessKey, setCustomizedTraceTopic, setEnabled, setEnableMsgTrace, setGroup, setHeartbeatBrokerInterval, setNameServer, setNamespace, setNamespaceV2, setPersistConsumerOffsetInterval, setPollNameServerInterval, setSecretKey, setUnitName, setUseTLS, setVipChannelEnabled

Methods inherited from class java.lang.Object

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

Constructor Details

RocketMQConsumerProperties

public RocketMQConsumerProperties()

Method Details

getMessageModel

public String getMessageModel()

setMessageModel

public RocketMQConsumerProperties setMessageModel(String messageModel)

getAllocateMessageQueueStrategy

public String getAllocateMessageQueueStrategy()

setAllocateMessageQueueStrategy

public void setAllocateMessageQueueStrategy(String allocateMessageQueueStrategy)

getSubscription

public String getSubscription()

setSubscription

public void setSubscription(String subscription)

getPush

public RocketMQConsumerProperties.Push getPush()

setPush

public void setPush(RocketMQConsumerProperties.Push push)

getPullTimeDelayMillsWhenException

public long getPullTimeDelayMillsWhenException()

setPullTimeDelayMillsWhenException

public RocketMQConsumerProperties setPullTimeDelayMillsWhenException(long pullTimeDelayMillsWhenException)

getConsumeFromWhere

public org.apache.rocketmq.common.consumer.ConsumeFromWhere getConsumeFromWhere()

setConsumeFromWhere

public RocketMQConsumerProperties setConsumeFromWhere(org.apache.rocketmq.common.consumer.ConsumeFromWhere consumeFromWhere)

getConsumeTimestamp

public String getConsumeTimestamp()

setConsumeTimestamp

public RocketMQConsumerProperties setConsumeTimestamp(String consumeTimestamp)

getPullThresholdForQueue

public int getPullThresholdForQueue()

setPullThresholdForQueue

public RocketMQConsumerProperties setPullThresholdForQueue(int pullThresholdForQueue)

getPullThresholdSizeForQueue

public int getPullThresholdSizeForQueue()

setPullThresholdSizeForQueue

public RocketMQConsumerProperties setPullThresholdSizeForQueue(int pullThresholdSizeForQueue)

getPullBatchSize

public int getPullBatchSize()

setPullBatchSize

public RocketMQConsumerProperties setPullBatchSize(int pullBatchSize)

getPull

public RocketMQConsumerProperties.Pull getPull()

setPull

public RocketMQConsumerProperties setPull(RocketMQConsumerProperties.Pull pull)

getConsumeMaxSpan

public int getConsumeMaxSpan()

setConsumeMaxSpan

public RocketMQConsumerProperties setConsumeMaxSpan(int consumeMaxSpan)