接口 com.taobao.metamorphosis.server.store.AppendCallback
的使用

使用 AppendCallback 的软件包

com.taobao.metamorphosis.gregor.master
com.taobao.metamorphosis.server.assembly
com.taobao.metamorphosis.server.store

com.taobao.metamorphosis.gregor.master 中 AppendCallback 的使用

实现 AppendCallback 的 com.taobao.metamorphosis.gregor.master 中的类

class

SamsaCommandProcessor.SyncAppendCallback append到message store的callback

com.taobao.metamorphosis.server.assembly 中 AppendCallback 的使用

实现 AppendCallback 的 com.taobao.metamorphosis.server.assembly 中的类

class

BrokerCommandProcessor.StoreAppendCallback append到message store的callback

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

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

void	MessageStore.append(List<Long> msgIds, List<PutCommand> putCmds, AppendCallback cb) Append多个消息，返回写入的位置
void	MessageStore.append(long msgId, PutCommand req, AppendCallback cb) Append单个消息，返回写入的位置
void	MessageStore.replayAppend(long offset, int length, int checksum, List<Long> msgIds, List<PutCommand> reqs, AppendCallback cb) 重放事务操作，如果消息没有存储成功，则重新存储，并返回新的位置