com.taobao.metamorphosis.server.store
类 MessageStoreManager

java.lang.Object
  com.taobao.metamorphosis.server.store.MessageStoreManager

所有已实现的接口：

Service

public class MessageStoreManager
extends Object
implements Service

消息存储管理器

作者：

boyan, wuhua

字段摘要

static int

HALF_DAY

构造方法摘要

MessageStoreManager(MetaConfig metaConfig, DeletePolicy deletePolicy)

方法摘要

int	chooseRandomPartition(String topic)
void	dispose()
Set<String>	getAllTopics()
MessageStore	getMessageStore(String topic, int partition)
Map<String,ConcurrentHashMap<Integer,MessageStore>>	getMessageStores()
int	getNumPartitions(String topic)
MessageStore	getOrCreateMessageStore(String topic, int partition)
MessageStore	getOrCreateMessageStore(String topic, int partition, long offsetIfCreate)
int	getTopicCount()
long	getTotalMessagesCount()
void	init()

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

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

字段详细信息

HALF_DAY

public static final int HALF_DAY

另请参见：

常量字段值

构造方法详细信息

MessageStoreManager

public MessageStoreManager(MetaConfig metaConfig,
                           DeletePolicy deletePolicy)

方法详细信息

getMessageStores

public Map<String,ConcurrentHashMap<Integer,MessageStore>> getMessageStores()

getTotalMessagesCount

public long getTotalMessagesCount()

getTopicCount

public int getTopicCount()

chooseRandomPartition

public int chooseRandomPartition(String topic)

getNumPartitions

public int getNumPartitions(String topic)

dispose

public void dispose()

指定者：

接口 Service 中的 dispose

init

public void init()

指定者：

接口 Service 中的 init

getAllTopics

public Set<String> getAllTopics()

getMessageStore

public MessageStore getMessageStore(String topic,
                                    int partition)

getOrCreateMessageStore

public MessageStore getOrCreateMessageStore(String topic,
                                            int partition)
                                     throws IOException

抛出：

IOException

getOrCreateMessageStore

public MessageStore getOrCreateMessageStore(String topic,
                                            int partition,
                                            long offsetIfCreate)
                                     throws IOException

抛出：

IOException