com.taobao.metamorphosis.metaslave
类 SlaveConsumerZooKeeper

java.lang.Object
  com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper
      com.taobao.metamorphosis.metaslave.SlaveConsumerZooKeeper

所有已实现的接口：

ZkClientChangedListener

public class SlaveConsumerZooKeeper
extends ConsumerZooKeeper

为slave接收消息扩展的ConsumerZooKeeper

从以下版本开始：

2011-6-27 下午03:04:11

作者：

无花

嵌套类摘要

从类 com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper 继承的嵌套类/接口

ConsumerZooKeeper.ZKLoadRebalanceListener

字段摘要

从类 com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper 继承的字段

consumerLoadBalanceListeners, metaZookeeper, zkClient

构造方法摘要

SlaveConsumerZooKeeper(MetaZookeeper metaZookeeper, RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig, int brokerId)

方法摘要

void	registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy) 注册订阅者

从类 com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper 继承的方法

commitOffsets, getBrokerConnectionListener, getConsumerUUID, onZkClientChanged, registerConsumerInternal, unRegisterConsumer

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

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

构造方法详细信息

SlaveConsumerZooKeeper

public SlaveConsumerZooKeeper(MetaZookeeper metaZookeeper,
                              RemotingClientWrapper remotingClient,
                              org.I0Itec.zkclient.ZkClient zkClient,
                              ZkUtils.ZKConfig zkConfig,
                              int brokerId)

方法详细信息

registerConsumer

public void registerConsumer(ConsumerConfig consumerConfig,
                             FetchManager fetchManager,
                             ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry,
                             OffsetStorage offsetStorage,
                             LoadBalanceStrategy loadBalanceStrategy)
                      throws Exception

从类 ConsumerZooKeeper 复制的描述

注册订阅者

覆盖：

类 ConsumerZooKeeper 中的 registerConsumer

抛出：

Exception