接口 com.taobao.metamorphosis.client.extension.producer.MessageRecoverManager.MessageRecoverer
的使用

使用 MessageRecoverManager.MessageRecoverer 的软件包

com.taobao.metamorphosis.client.extension.producer

com.taobao.metamorphosis.client.extension.producer 中 MessageRecoverManager.MessageRecoverer 的使用

实现 MessageRecoverManager.MessageRecoverer 的 com.taobao.metamorphosis.client.extension.producer 中的类

class

AsyncMetaMessageProducer 异步单向发送消息给服务器的生产者实现.

声明为 MessageRecoverManager.MessageRecoverer 的 com.taobao.metamorphosis.client.extension.producer 中的字段

protected MessageRecoverManager.MessageRecoverer

LocalMessageStorageManager.messageRecoverer

参数类型为 MessageRecoverManager.MessageRecoverer 的 com.taobao.metamorphosis.client.extension.producer 中的方法

boolean	OrderedLocalMessageStorageManager.recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息,可多次调用(保证对某主题的恢复任务最多只有一个在运行)
boolean	MessageRecoverManager.recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息
boolean	LocalMessageStorageManager.recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息,可多次调用(保证对某主题的恢复任务最多只有一个在运行)
void	MessageRecoverManager.setMessageRecoverer(MessageRecoverManager.MessageRecoverer recoverer) 设置如何恢复消息的处理器
void	LocalMessageStorageManager.setMessageRecoverer(MessageRecoverManager.MessageRecoverer recoverer)

参数类型为 MessageRecoverManager.MessageRecoverer 的 com.taobao.metamorphosis.client.extension.producer 中的构造方法

LocalMessageStorageManager(MetaClientConfig metaClientConfig, String path, MessageRecoverManager.MessageRecoverer messageRecoverer)