com.alibaba.rocketmq.client.impl.consumer

类 PullAPIWrapper

java.lang.Object

com.alibaba.rocketmq.client.impl.consumer.PullAPIWrapper

public class PullAPIWrapper
extends Object

从以下版本开始:

2013-7-24

作者:

shijia.wxr

构造器概要

构造器

构造器和说明
PullAPIWrapper(MQClientInstance mQClientFactory, String consumerGroup, boolean unitMode)

方法概要

方法

限定符和类型	方法和说明
void	executeHook(FilterMessageContext context)
long	getDefaultBrokerId()
boolean	hasHook()
boolean	isConnectBrokerByUser()
PullResult	processPullResult(MessageQueue mq, PullResult pullResult, SubscriptionData subscriptionData)
PullResult	pullKernelImpl(MessageQueue mq, String subExpression, long subVersion, long offset, int maxNums, int sysFlag, long commitOffset, long brokerSuspendMaxTimeMillis, long timeoutMillis, CommunicationMode communicationMode, PullCallback pullCallback)
int	randomNum()
long	recalculatePullFromWhichNode(MessageQueue mq)
void	registerFilterMessageHook(ArrayList<FilterMessageHook> filterMessageHookList)
void	setConnectBrokerByUser(boolean connectBrokerByUser)
void	setDefaultBrokerId(long defaultBrokerId)
void	updatePullFromWhichNode(MessageQueue mq, long brokerId)

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

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

构造器详细资料

PullAPIWrapper

public PullAPIWrapper(MQClientInstance mQClientFactory,
              String consumerGroup,
              boolean unitMode)

方法详细资料

updatePullFromWhichNode

public void updatePullFromWhichNode(MessageQueue mq,
                           long brokerId)

randomNum

public int randomNum()

processPullResult

public PullResult processPullResult(MessageQueue mq,
                           PullResult pullResult,
                           SubscriptionData subscriptionData)

recalculatePullFromWhichNode

public long recalculatePullFromWhichNode(MessageQueue mq)

pullKernelImpl

public PullResult pullKernelImpl(MessageQueue mq,
                        String subExpression,
                        long subVersion,
                        long offset,
                        int maxNums,
                        int sysFlag,
                        long commitOffset,
                        long brokerSuspendMaxTimeMillis,
                        long timeoutMillis,
                        CommunicationMode communicationMode,
                        PullCallback pullCallback)
                          throws MQClientException,
                                 com.alibaba.rocketmq.remoting.exception.RemotingException,
                                 MQBrokerException,
                                 InterruptedException

抛出:

MQClientException

com.alibaba.rocketmq.remoting.exception.RemotingException

MQBrokerException

InterruptedException

hasHook

public boolean hasHook()

registerFilterMessageHook

public void registerFilterMessageHook(ArrayList<FilterMessageHook> filterMessageHookList)

executeHook

public void executeHook(FilterMessageContext context)

getDefaultBrokerId

public long getDefaultBrokerId()

setDefaultBrokerId

public void setDefaultBrokerId(long defaultBrokerId)

isConnectBrokerByUser

public boolean isConnectBrokerByUser()

setConnectBrokerByUser

public void setConnectBrokerByUser(boolean connectBrokerByUser)