com.taobao.metamorphosis.client.extension.producer
接口 MessageRecoverManager

所有超级接口：

Shutdownable

所有已知实现类：

LocalMessageStorageManager, OrderedLocalMessageStorageManager

public interface MessageRecoverManager
extends Shutdownable

消息暂存和recover管理器的抽象

从以下版本开始：

2011-10-27 下午3:34:12

作者：

无花

嵌套类摘要

static interface

MessageRecoverManager.MessageRecoverer 指定消息如何recover

方法摘要

void	append(Message message, Partition partition) 存入消息
int	getMessageCount(String topic, Partition partition) 消息条数
void	recover() 全部恢复
boolean	recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息
void	setMessageRecoverer(MessageRecoverManager.MessageRecoverer recoverer) 设置如何恢复消息的处理器

从接口 com.taobao.metamorphosis.client.Shutdownable 继承的方法

shutdown

方法详细信息

recover

void recover()

全部恢复

recover

boolean recover(String topic,
                Partition partition,
                MessageRecoverManager.MessageRecoverer recoverer)

触发恢复一个主题一个分区的消息

参数：

topic -

partition -

recoverer - 恢复出来的消息的处理器

返回：

是否真正提交了恢复任务

append

void append(Message message,
            Partition partition)
            throws IOException

存入消息

参数：

message -

partition -

抛出：

IOException

getMessageCount

int getMessageCount(String topic,
                    Partition partition)

消息条数

参数：

topic -

partition -

返回：

setMessageRecoverer

void setMessageRecoverer(MessageRecoverManager.MessageRecoverer recoverer)

设置如何恢复消息的处理器

参数：

recoverer -