com.taobao.metamorphosis.metaslave
类 SlaveMetaMessageSessionFactory
java.lang.Object
com.taobao.metamorphosis.client.MetaMessageSessionFactory
com.taobao.metamorphosis.metaslave.SlaveMetaMessageSessionFactory
- 所有已实现的接口:
- MessageSessionFactory, Shutdownable
public class SlaveMetaMessageSessionFactory
- extends MetaMessageSessionFactory
- 从以下版本开始:
- 2011-6-27 下午06:44:48
- 作者:
- 无花
从类 com.taobao.metamorphosis.client.MetaMessageSessionFactory 继承的方法 |
addChild, checkConsumerConfig, createConsumer, createConsumer, createConsumer, createLoadBalanceStrategy, createProducer, createProducer, createProducer, createProducer, createTopicBrowser, createTopicBrowser, getChildren, getConsumerZooKeeper, getMetaClientConfig, getPartitionsForTopic, getProducerZooKeeper, getRecoverStorageManager, getRemotingClient, getStats, getStats, getStats, getStats, getSubscribeInfoManager, removeChild, shutdown |
从类 java.lang.Object 继承的方法 |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
create
public static SlaveMetaMessageSessionFactory create(MetaClientConfig metaClientConfig,
int brokerId)
throws MetaClientException
- 抛出:
MetaClientException
initConsumerZooKeeper
protected ConsumerZooKeeper initConsumerZooKeeper(RemotingClientWrapper remotingClient,
org.I0Itec.zkclient.ZkClient zkClient,
ZkUtils.ZKConfig zkConfig)
- 覆盖:
- 类
MetaMessageSessionFactory
中的 initConsumerZooKeeper
Copyright © 2010–2013. All rights reserved.