com.taobao.metamorphosis.client.extension.consumer
类 RecoverNotifyManager

java.lang.Object
  com.taobao.metamorphosis.client.consumer.AbstractRecoverManager
      com.taobao.metamorphosis.client.extension.consumer.RecoverNotifyManager

所有已实现的接口：

RecoverManager, Shutdownable

public class RecoverNotifyManager
extends AbstractRecoverManager

Recover存储管理器，需要recover的消息存到notify.
unsupported,"notify" is not open source yet

从以下版本开始：

2011-10-31 下午3:50:52

作者：

无花

字段摘要

从类 com.taobao.metamorphosis.client.consumer.AbstractRecoverManager 继承的字段

deserializer, serializer

构造方法摘要

RecoverNotifyManager(MetaMessageSessionFactory factory, String recoverNotifyTopic, RecoverManager next)

方法摘要

void	append(String group, Message message) 存入一个消息
boolean	isStarted() 是否已经启动
void	shutdown()
void	start(MetaClientConfig metaClientConfig) 启动recover

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

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

构造方法详细信息

RecoverNotifyManager

public RecoverNotifyManager(MetaMessageSessionFactory factory,
                            String recoverNotifyTopic,
                            RecoverManager next)

方法详细信息

isStarted

public boolean isStarted()

从接口 RecoverManager 复制的描述

是否已经启动

返回：

start

public void start(MetaClientConfig metaClientConfig)

从接口 RecoverManager 复制的描述

启动recover

append

public void append(String group,
                   Message message)
            throws IOException

从接口 RecoverManager 复制的描述

存入一个消息

抛出：

IOException

shutdown

public void shutdown()
              throws MetaClientException

抛出：

MetaClientException