org.zodiac.rocketmq.client.consumer

类 DefaultRocketMQLitePullConsumer

java.lang.Object

org.apache.rocketmq.client.ClientConfig

org.apache.rocketmq.client.consumer.DefaultLitePullConsumer

org.zodiac.rocketmq.client.consumer.DefaultRocketMQLitePullConsumer

所有已实现的接口:

org.apache.rocketmq.client.consumer.LitePullConsumer

public class DefaultRocketMQLitePullConsumer
extends org.apache.rocketmq.client.consumer.DefaultLitePullConsumer

字段概要

字段

限定符和类型	字段和说明
private String	selectorExpression
private RocketMQSelectorType	selectorType
private Set<String>	subscribedTopics
private List<String>	topics

从类继承的字段 org.apache.rocketmq.client.ClientConfig

accessChannel, namespace, SEND_MESSAGE_WITH_VIP_CHANNEL_PROPERTY

构造器概要

构造器

构造器和说明
DefaultRocketMQLitePullConsumer()
DefaultRocketMQLitePullConsumer(org.apache.rocketmq.remoting.RPCHook rpcHook)
DefaultRocketMQLitePullConsumer(String consumerGroup)
DefaultRocketMQLitePullConsumer(String consumerGroup, org.apache.rocketmq.remoting.RPCHook rpcHook)
DefaultRocketMQLitePullConsumer(String namespace, String consumerGroup, org.apache.rocketmq.remoting.RPCHook rpcHook)

方法概要

限定符和类型	方法和说明
void	addTopic(String topic)
String	getSelectorExpression()
RocketMQSelectorType	getSelectorType()
List<String>	getTopics()
void	initialize()
void	removeTopic(String topic)
void	removeTopics(List<String> topics)
void	reset()
void	setSelectorExpression(String selectorExpression)
void	setSelectorType(RocketMQSelectorType selectorType)
void	setTopics(List<String> topics)
void	subscribe(String topic, org.apache.rocketmq.client.consumer.MessageSelector messageSelector)
void	subscribe(String topic, String subExpression)
private void	subscribeTopics()
void	uninitialize()
void	unsubscribe(String topic)
private void	unsubscribeTopics()

从类继承的方法 org.apache.rocketmq.client.consumer.DefaultLitePullConsumer

assign, commitSync, committed, fetchMessageQueues, getAllocateMessageQueueStrategy, getAutoCommitIntervalMillis, getBrokerSuspendMaxTimeMillis, getConsumeFromWhere, getConsumeMaxSpan, getConsumerGroup, getConsumerPullTimeoutMillis, getConsumerTimeoutMillisWhenSuspend, getConsumeTimestamp, getCustomizedTraceTopic, getDefaultBrokerId, getMessageModel, getMessageQueueListener, getOffsetStore, getPollTimeoutMillis, getPullBatchSize, getPullThreadNums, getPullThresholdForAll, getPullThresholdForQueue, getPullThresholdSizeForQueue, getTopicMetadataCheckIntervalMillis, getTraceDispatcher, isAutoCommit, isConnectBrokerByUser, isEnableMsgTrace, isRunning, isUnitMode, offsetForTimestamp, pause, poll, poll, registerTopicMessageQueueChangeListener, resume, seek, seekToBegin, seekToEnd, setAllocateMessageQueueStrategy, setAutoCommit, setAutoCommitIntervalMillis, setConnectBrokerByUser, setConsumeFromWhere, setConsumeMaxSpan, setConsumerGroup, setConsumerPullTimeoutMillis, setConsumerTimeoutMillisWhenSuspend, setConsumeTimestamp, setCustomizedTraceTopic, setDefaultBrokerId, setEnableMsgTrace, setMessageModel, setMessageQueueListener, setOffsetStore, setPollTimeoutMillis, setPullBatchSize, setPullThreadNums, setPullThresholdForAll, setPullThresholdForQueue, setPullThresholdSizeForQueue, setTopicMetadataCheckIntervalMillis, setUnitMode, shutdown, start, updateNameServerAddress

从类继承的方法 org.apache.rocketmq.client.ClientConfig

buildMQClientId, changeInstanceNameToPID, cloneClientConfig, getAccessChannel, getClientCallbackExecutorThreads, getClientIP, getHeartbeatBrokerInterval, getInstanceName, getLanguage, getNamespace, getNamesrvAddr, getPersistConsumerOffsetInterval, getPollNameServerInterval, getPullTimeDelayMillsWhenException, getUnitName, isUseTLS, isVipChannelEnabled, queuesWithNamespace, queueWithNamespace, resetClientConfig, setAccessChannel, setClientCallbackExecutorThreads, setClientIP, setHeartbeatBrokerInterval, setInstanceName, setLanguage, setNamespace, setNamesrvAddr, setPersistConsumerOffsetInterval, setPollNameServerInterval, setPullTimeDelayMillsWhenException, setUnitName, setUseTLS, setVipChannelEnabled, toString, withNamespace, withNamespace, withoutNamespace, withoutNamespace

从类继承的方法 java.lang.Object

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

字段详细资料

subscribedTopics

private volatile Set<String> subscribedTopics

selectorType

private RocketMQSelectorType selectorType

selectorExpression

private String selectorExpression

topics

private final List<String> topics

构造器详细资料

DefaultRocketMQLitePullConsumer

public DefaultRocketMQLitePullConsumer()

DefaultRocketMQLitePullConsumer

public DefaultRocketMQLitePullConsumer(String consumerGroup)

DefaultRocketMQLitePullConsumer

public DefaultRocketMQLitePullConsumer(org.apache.rocketmq.remoting.RPCHook rpcHook)

DefaultRocketMQLitePullConsumer

public DefaultRocketMQLitePullConsumer(String consumerGroup,
                                       org.apache.rocketmq.remoting.RPCHook rpcHook)

DefaultRocketMQLitePullConsumer

public DefaultRocketMQLitePullConsumer(String namespace,
                                       String consumerGroup,
                                       org.apache.rocketmq.remoting.RPCHook rpcHook)

方法详细资料

getSelectorType

public RocketMQSelectorType getSelectorType()

setSelectorType

public void setSelectorType(RocketMQSelectorType selectorType)

getSelectorExpression

public String getSelectorExpression()

setSelectorExpression

public void setSelectorExpression(String selectorExpression)

getTopics

public List<String> getTopics()

addTopic

public void addTopic(String topic)

setTopics

public void setTopics(List<String> topics)

removeTopic

public void removeTopic(String topic)

removeTopics

public void removeTopics(List<String> topics)

subscribe

public void subscribe(String topic,
                      String subExpression)
               throws org.apache.rocketmq.client.exception.MQClientException

指定者:

subscribe 在接口中 org.apache.rocketmq.client.consumer.LitePullConsumer

覆盖:

subscribe 在类中 org.apache.rocketmq.client.consumer.DefaultLitePullConsumer

抛出:

org.apache.rocketmq.client.exception.MQClientException

subscribe

public void subscribe(String topic,
                      org.apache.rocketmq.client.consumer.MessageSelector messageSelector)
               throws org.apache.rocketmq.client.exception.MQClientException

指定者:

subscribe 在接口中 org.apache.rocketmq.client.consumer.LitePullConsumer

覆盖:

subscribe 在类中 org.apache.rocketmq.client.consumer.DefaultLitePullConsumer

抛出:

org.apache.rocketmq.client.exception.MQClientException

unsubscribe

public void unsubscribe(String topic)

指定者:

unsubscribe 在接口中 org.apache.rocketmq.client.consumer.LitePullConsumer

覆盖:

unsubscribe 在类中 org.apache.rocketmq.client.consumer.DefaultLitePullConsumer

reset

public void reset()
           throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

initialize

public void initialize()
                throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

uninitialize

public void uninitialize()
                  throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

subscribeTopics

private void subscribeTopics()
                      throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

unsubscribeTopics

private void unsubscribeTopics()
                        throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException