类 com.taobao.metamorphosis.client.consumer.SubscribeInfoManager
的使用

使用 SubscribeInfoManager 的软件包

com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer

com.taobao.metamorphosis.client 中 SubscribeInfoManager 的使用

返回 SubscribeInfoManager 的 com.taobao.metamorphosis.client 中的方法

SubscribeInfoManager

MetaMessageSessionFactory.getSubscribeInfoManager() 返回订阅关系管理器

com.taobao.metamorphosis.client.consumer 中 SubscribeInfoManager 的使用

参数类型为 SubscribeInfoManager 的 com.taobao.metamorphosis.client.consumer 中的方法

static ConcurrentHashMap<String,ConcurrentHashMap<String,SubscriberInfo>>

SubscribeInfoManagerAccessor.getGroupTopicSubcriberRegistry(SubscribeInfoManager subscribeInfoManager)

参数类型为 SubscribeInfoManager 的 com.taobao.metamorphosis.client.consumer 中的构造方法

RecoverStorageManager(MetaClientConfig metaClientConfig, SubscribeInfoManager subscribeInfoManager)

SimpleMessageConsumer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, ConsumerConfig consumerConfig, ConsumerZooKeeper consumerZooKeeper, ProducerZooKeeper producerZooKeeper, SubscribeInfoManager subscribeInfoManager, RecoverManager recoverManager, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)