接口 com.taobao.metamorphosis.server.network.PutCallback
的使用

使用 PutCallback 的软件包
com.taobao.metamorphosis.gregor.master   
com.taobao.metamorphosis.gregor.slave   
com.taobao.metamorphosis.server   
com.taobao.metamorphosis.server.assembly   
 

com.taobao.metamorphosis.gregor.masterPutCallback 的使用
 

参数类型为 PutCallbackcom.taobao.metamorphosis.gregor.master 中的方法
 void SamsaCommandProcessor.processPutCommand(PutCommand request, SessionContext sessionContext, PutCallback cb)
          处理put请求,只有当master/slave全部写入成功的时候才认为写入成功
 

参数类型为 PutCallbackcom.taobao.metamorphosis.gregor.master 中的构造方法
SamsaCommandProcessor.SyncAppendCallback(int partition, String partitionString, PutCommand request, long messageId, PutCallback cb)
           
 

com.taobao.metamorphosis.gregor.slavePutCallback 的使用
 

参数类型为 PutCallbackcom.taobao.metamorphosis.gregor.slave 中的方法
 void SyncCommandProcessor.processSyncCommand(SyncCommand request, SessionContext sessionContext, PutCallback cb)
          处理同步命令
 void GregorCommandProcessor.processSyncCommand(SyncCommand request, SessionContext sessionContext, PutCallback cb)
           
 

com.taobao.metamorphosis.serverPutCallback 的使用
 

参数类型为 PutCallbackcom.taobao.metamorphosis.server 中的方法
 void CommandProcessorFilter.processPutCommand(PutCommand request, SessionContext sessionContext, PutCallback cb)
           
 void CommandProcessor.processPutCommand(PutCommand request, SessionContext sessionContext, PutCallback cb)
           
 

com.taobao.metamorphosis.server.assemblyPutCallback 的使用
 

参数类型为 PutCallbackcom.taobao.metamorphosis.server.assembly 中的方法
 void TransactionalCommandProcessor.processPutCommand(PutCommand cmd, SessionContext context, PutCallback cb)
           
 void BrokerCommandProcessor.processPutCommand(PutCommand request, SessionContext sessionContext, PutCallback cb)
           
 

参数类型为 PutCallbackcom.taobao.metamorphosis.server.assembly 中的构造方法
BrokerCommandProcessor.StoreAppendCallback(int partition, String partitionString, PutCommand request, long messageId, PutCallback cb)
           
 



Copyright © 2010–2013. All rights reserved.