类 com.taobao.metamorphosis.server.store.MessageStore
的使用

使用 MessageStore 的软件包

com.taobao.metamorphosis.server.store
com.taobao.metamorphosis.server.transaction
com.taobao.metamorphosis.server.transaction.store

com.taobao.metamorphosis.server.store 中 MessageStore 的使用

返回 MessageStore 的 com.taobao.metamorphosis.server.store 中的方法

MessageStore	MessageStoreManager.getMessageStore(String topic, int partition)
MessageStore	MessageStoreManager.getOrCreateMessageStore(String topic, int partition)
MessageStore	MessageStoreManager.getOrCreateMessageStore(String topic, int partition, long offsetIfCreate)

返回变量类型为 MessageStore 的类型的 com.taobao.metamorphosis.server.store 中的方法

Map<String,ConcurrentHashMap<Integer,MessageStore>>

MessageStoreManager.getMessageStores()

com.taobao.metamorphosis.server.transaction 中 MessageStore 的使用

参数类型为 MessageStore 的 com.taobao.metamorphosis.server.transaction 中的方法

void	TransactionStore.addMessage(MessageStore store, long msgId, PutCommand cmd, JournalLocation location)

com.taobao.metamorphosis.server.transaction.store 中 MessageStore 的使用

声明为 MessageStore 的 com.taobao.metamorphosis.server.transaction.store 中的字段

MessageStore

JournalTransactionStore.AddMsgOperation.store

返回变量类型为 MessageStore 的类型的 com.taobao.metamorphosis.server.transaction.store 中的方法

Map<MessageStore,List<Long>>	JournalTransactionStore.Tx.getMsgIds()
Map<MessageStore,Queue<JournalTransactionStore.TxOperation>>	JournalTransactionStore.Tx.getOperations()
Map<MessageStore,List<PutCommand>>	JournalTransactionStore.Tx.getPutCommands()

参数类型为 MessageStore 的 com.taobao.metamorphosis.server.transaction.store 中的方法

void	JournalTransactionStore.Tx.add(MessageStore store, long msgId, PutCommand putCmd)
void	JournalTransactionStore.addMessage(MessageStore store, long msgId, PutCommand putCmd, JournalLocation location) 添加消息，为了保证添加顺序，这里不得不加锁

参数类型为 MessageStore 的 com.taobao.metamorphosis.server.transaction.store 中的构造方法

JournalTransactionStore.AddMsgOperation(MessageStore store, long msgId, PutCommand putCmd)