com.taobao.metamorphosis.client.consumer
类 RecoverStorageManager

java.lang.Object
  com.taobao.metamorphosis.client.consumer.AbstractRecoverManager
      com.taobao.metamorphosis.client.consumer.RecoverStorageManager

所有已实现的接口：

RecoverManager, Shutdownable

public class RecoverStorageManager
extends AbstractRecoverManager

Recover存储管理器

作者：

boyan

字段摘要

static String

META_RECOVER_STORE_PATH

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

deserializer, serializer

构造方法摘要

RecoverStorageManager(MetaClientConfig metaClientConfig, SubscribeInfoManager subscribeInfoManager)

方法摘要

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

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

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

字段详细信息

META_RECOVER_STORE_PATH

public static final String META_RECOVER_STORE_PATH

构造方法详细信息

RecoverStorageManager

public RecoverStorageManager(MetaClientConfig metaClientConfig,
                             SubscribeInfoManager subscribeInfoManager)

方法详细信息

isStarted

public boolean isStarted()

从接口 RecoverManager 复制的描述

是否已经启动

返回：

start

public void start(MetaClientConfig metaClientConfig)

从接口 RecoverManager 复制的描述

启动recover

shutdown

public void shutdown()

append

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

从接口 RecoverManager 复制的描述

存入一个消息

抛出：

IOException

getOrCreateStore

public Store getOrCreateStore(String topic,
                              String group)