com.taobao.metamorphosis.client.extension.producer
类 OrderedLocalMessageStorageManager

java.lang.Object
  com.taobao.metamorphosis.client.extension.producer.LocalMessageStorageManager
      com.taobao.metamorphosis.client.extension.producer.OrderedLocalMessageStorageManager

所有已实现的接口：

MessageRecoverManager, Shutdownable

public class OrderedLocalMessageStorageManager
extends LocalMessageStorageManager

针对顺序消息做了特殊处理的LocalMessageStorageManager

从以下版本开始：

2011-10-27 下午3:21:32

作者：

无花

嵌套类摘要

从接口 com.taobao.metamorphosis.client.extension.producer.MessageRecoverManager 继承的嵌套类/接口

MessageRecoverManager.MessageRecoverer

字段摘要

从类 com.taobao.metamorphosis.client.extension.producer.LocalMessageStorageManager 继承的字段

DEFAULT_META_LOCALMESSAGE_PATH, deserializer, messageRecoverer, META_LOCALMESSAGE_PATH, SPLIT, threadPoolExecutor, topicRecoverTaskMap, topicStoreMap

构造方法摘要

OrderedLocalMessageStorageManager(MetaClientConfig metaClientConfig)

方法摘要

protected Store	newStore(String name)
void	recover() 全部恢复
boolean	recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息,可多次调用(保证对某主题的恢复任务最多只有一个在运行)

从类 com.taobao.metamorphosis.client.extension.producer.LocalMessageStorageManager 继承的方法

append, generateKey, getMessageCount, getOrCreateStore, setMessageRecoverer, shutdown

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

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

构造方法详细信息

OrderedLocalMessageStorageManager

public OrderedLocalMessageStorageManager(MetaClientConfig metaClientConfig)

方法详细信息

recover

public void recover()

从接口 MessageRecoverManager 复制的描述

全部恢复

指定者：

接口 MessageRecoverManager 中的 recover

覆盖：

类 LocalMessageStorageManager 中的 recover

recover

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

触发恢复一个主题一个分区的消息,可多次调用(保证对某主题的恢复任务最多只有一个在运行)

指定者：

接口 MessageRecoverManager 中的 recover

覆盖：

类 LocalMessageStorageManager 中的 recover

参数：

topic -

partition -

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

返回：

是否真正提交了恢复任务

newStore

protected Store newStore(String name)
                  throws IOException

覆盖：

类 LocalMessageStorageManager 中的 newStore

抛出：

IOException