com.alibaba.rocketmq.client.impl.factory

类 MQClientInstance

java.lang.Object

com.alibaba.rocketmq.client.impl.factory.MQClientInstance

public class MQClientInstance
extends Object

从以下版本开始:

2013-6-15

作者:

shijia.wxr

构造器概要

构造器

构造器和说明
MQClientInstance(ClientConfig clientConfig, int instanceIndex, String clientId)
MQClientInstance(ClientConfig clientConfig, int instanceIndex, String clientId, com.alibaba.rocketmq.remoting.RPCHook rpcHook)

方法概要

方法

限定符和类型	方法和说明
void	adjustThreadPool()
ConsumeMessageDirectlyResult	consumeMessageDirectly(MessageExt msg, String consumerGroup, String brokerName)
ConsumerRunningInfo	consumerRunningInfo(String consumerGroup)
void	doRebalance()
String	findBrokerAddrByTopic(String topic)
FindBrokerResult	findBrokerAddressInAdmin(String brokerName)
String	findBrokerAddressInPublish(String brokerName)
FindBrokerResult	findBrokerAddressInSubscribe(String brokerName, long brokerId, boolean onlyThisBroker)
List<String>	findConsumerIdList(String topic, String group)
TopicRouteData	getAnExistTopicRouteData(String topic)
long	getBootTimestamp()
String	getClientId()
ConsumerStatsManager	getConsumerStatsManager()
Map<MessageQueue,Long>	getConsumerStatus(String topic, String group)
DefaultMQProducer	getDefaultMQProducer()
MQAdminImpl	getMQAdminImpl()
MQClientAPIImpl	getMQClientAPIImpl()
PullMessageService	getPullMessageService()
ScheduledExecutorService	getScheduledExecutorService()
ConcurrentHashMap<String,TopicRouteData>	getTopicRouteTable()
void	rebalanceImmediately()
boolean	registerAdminExt(String group, MQAdminExtInner admin)
boolean	registerConsumer(String group, MQConsumerInner consumer)
boolean	registerProducer(String group, DefaultMQProducerImpl producer)
void	resetOffset(String topic, String group, Map<MessageQueue,Long> offsetTable)
MQConsumerInner	selectConsumer(String group)
MQProducerInner	selectProducer(String group)
void	sendHeartbeatToAllBrokerWithLock()
void	shutdown()
void	start()
static TopicPublishInfo	topicRouteData2TopicPublishInfo(String topic, TopicRouteData route)
static Set<MessageQueue>	topicRouteData2TopicSubscribeInfo(String topic, TopicRouteData route)
void	unregisterAdminExt(String group)
void	unregisterConsumer(String group)
void	unregisterProducer(String group)
void	updateTopicRouteInfoFromNameServer()
boolean	updateTopicRouteInfoFromNameServer(String topic)
boolean	updateTopicRouteInfoFromNameServer(String topic, boolean isDefault, DefaultMQProducer defaultMQProducer)

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

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

构造器详细资料

MQClientInstance

public MQClientInstance(ClientConfig clientConfig,
                int instanceIndex,
                String clientId,
                com.alibaba.rocketmq.remoting.RPCHook rpcHook)

MQClientInstance

public MQClientInstance(ClientConfig clientConfig,
                int instanceIndex,
                String clientId)

方法详细资料

start

public void start()
           throws MQClientException

抛出:

MQClientException

sendHeartbeatToAllBrokerWithLock

public void sendHeartbeatToAllBrokerWithLock()

updateTopicRouteInfoFromNameServer

public void updateTopicRouteInfoFromNameServer()

updateTopicRouteInfoFromNameServer

public boolean updateTopicRouteInfoFromNameServer(String topic)

updateTopicRouteInfoFromNameServer

public boolean updateTopicRouteInfoFromNameServer(String topic,
                                         boolean isDefault,
                                         DefaultMQProducer defaultMQProducer)

topicRouteData2TopicPublishInfo

public static TopicPublishInfo topicRouteData2TopicPublishInfo(String topic,
                                               TopicRouteData route)

topicRouteData2TopicSubscribeInfo

public static Set<MessageQueue> topicRouteData2TopicSubscribeInfo(String topic,
                                                  TopicRouteData route)

shutdown

public void shutdown()

registerConsumer

public boolean registerConsumer(String group,
                       MQConsumerInner consumer)

unregisterConsumer

public void unregisterConsumer(String group)

registerProducer

public boolean registerProducer(String group,
                       DefaultMQProducerImpl producer)

unregisterProducer

public void unregisterProducer(String group)

registerAdminExt

public boolean registerAdminExt(String group,
                       MQAdminExtInner admin)

unregisterAdminExt

public void unregisterAdminExt(String group)

rebalanceImmediately

public void rebalanceImmediately()

doRebalance

public void doRebalance()

selectProducer

public MQProducerInner selectProducer(String group)

selectConsumer

public MQConsumerInner selectConsumer(String group)

findBrokerAddressInAdmin

public FindBrokerResult findBrokerAddressInAdmin(String brokerName)

findBrokerAddressInPublish

public String findBrokerAddressInPublish(String brokerName)

findBrokerAddressInSubscribe

public FindBrokerResult findBrokerAddressInSubscribe(String brokerName,
                                            long brokerId,
                                            boolean onlyThisBroker)

findConsumerIdList

public List<String> findConsumerIdList(String topic,
                              String group)

findBrokerAddrByTopic

public String findBrokerAddrByTopic(String topic)

resetOffset

public void resetOffset(String topic,
               String group,
               Map<MessageQueue,Long> offsetTable)

getConsumerStatus

public Map<MessageQueue,Long> getConsumerStatus(String topic,
                                       String group)

getAnExistTopicRouteData

public TopicRouteData getAnExistTopicRouteData(String topic)

getMQClientAPIImpl

public MQClientAPIImpl getMQClientAPIImpl()

getMQAdminImpl

public MQAdminImpl getMQAdminImpl()

getClientId

public String getClientId()

getBootTimestamp

public long getBootTimestamp()

getScheduledExecutorService

public ScheduledExecutorService getScheduledExecutorService()

getPullMessageService

public PullMessageService getPullMessageService()

getDefaultMQProducer

public DefaultMQProducer getDefaultMQProducer()

getTopicRouteTable

public ConcurrentHashMap<String,TopicRouteData> getTopicRouteTable()

adjustThreadPool

public void adjustThreadPool()

consumeMessageDirectly

public ConsumeMessageDirectlyResult consumeMessageDirectly(MessageExt msg,
                                                  String consumerGroup,
                                                  String brokerName)

consumerRunningInfo

public ConsumerRunningInfo consumerRunningInfo(String consumerGroup)

getConsumerStatsManager

public ConsumerStatsManager getConsumerStatsManager()