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 继承的字段
MAX_SCHEDULE_WRITTEN_BYTES, metaZookeeper, producerZooKeeper, remotingClient, sessionIdGenerator, TCP_NO_DELAY
 
方法摘要
static SlaveMetaMessageSessionFactory create(MetaClientConfig metaClientConfig, int brokerId)
           
protected  ConsumerZooKeeper initConsumerZooKeeper(RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig)
           
 
从类 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.