接口 com.taobao.metamorphosis.client.consumer.RecoverManager
的使用

使用 RecoverManager 的软件包

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

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

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

RecoverManager

MetaMessageSessionFactory.getRecoverStorageManager() 返回本地恢复消息管理器

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

protected MessageConsumer

MetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, RecoverManager recoverManager0)

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

实现 RecoverManager 的 com.taobao.metamorphosis.client.consumer 中的类

class	AbstractRecoverManager
class	RecoverStorageManager Recover存储管理器

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

SimpleMessageConsumer.LocalRecoverPolicy(RecoverManager recoverManager)

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

com.taobao.metamorphosis.client.extension 中 RecoverManager 的使用

参数类型为 RecoverManager 的 com.taobao.metamorphosis.client.extension 中的方法

protected MessageConsumer

MetaBroadcastMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig, RecoverManager recoverManager)

com.taobao.metamorphosis.client.extension.consumer 中 RecoverManager 的使用

实现 RecoverManager 的 com.taobao.metamorphosis.client.extension.consumer 中的类

class

RecoverNotifyManager Recover存储管理器，需要recover的消息存到notify.

返回 RecoverManager 的 com.taobao.metamorphosis.client.extension.consumer 中的方法

RecoverManager	ConsumerRecoverType.getNotifyRecoverManager(MetaMessageSessionFactory factory, String notifyRecoverTopic)
RecoverManager	ConsumerRecoverType.getRecoverManager(MetaMessageSessionFactory factory)

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

RecoverNotifyManager(MetaMessageSessionFactory factory, String recoverNotifyTopic, RecoverManager next)