com.taobao.metamorphosis.gregor.slave
类 GregorCommandProcessor

java.lang.Object
  继承者 com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor
      继承者 com.taobao.metamorphosis.gregor.slave.GregorCommandProcessor
所有已实现的接口:
SyncCommandProcessor, CommandProcessor, Service

public class GregorCommandProcessor
extends BrokerCommandProcessor
implements SyncCommandProcessor

Slave的协议处理器

作者:
boyan(boyan@taobao.com)

嵌套类摘要
 
从类 com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor 继承的嵌套类/接口
BrokerCommandProcessor.StoreAppendCallback
 
字段摘要
static org.apache.commons.logging.Log log
           
 
从类 com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor 继承的字段
brokerZooKeeper, consumerFilterManager, executorsManager, idWorker, metaConfig, remotingServer, statsManager, storeManager
 
构造方法摘要
GregorCommandProcessor()
           
GregorCommandProcessor(MessageStoreManager storeManager, ExecutorsManager executorsManager, StatsManager statsManager, com.taobao.gecko.service.RemotingServer remotingServer, MetaConfig metaConfig, IdWorker idWorker, BrokerZooKeeper brokerZooKeeper, ConsumerFilterManager consumerFilterManager)
           
 
方法摘要
 void processSyncCommand(SyncCommand request, SessionContext sessionContext, PutCallback cb)
          处理同步命令
 
从类 com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor 继承的方法
beginTransaction, commitTransaction, dispose, forgetTransaction, genErrorMessage, genPutResultString, getBrokerZooKeeper, getConsumerFilterManager, getExecutorsManager, getIdWorker, getMetaConfig, getPartition, getPreparedTransactions, getRemotingServer, getStatsManager, getStoreManager, getTransaction, init, prepareTransaction, processGetCommand, processGetCommand, processOffsetCommand, processPutCommand, processQuitCommand, processStatCommand, processVesionCommand, removeTransaction, rollbackTransaction, setBrokerZooKeeper, setConsumerFilterManager, setExecutorsManager, setIdWorker, setMetaConfig, setRemotingServer, setStatsManager, setStoreManager
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

字段详细信息

log

public static final org.apache.commons.logging.Log log
构造方法详细信息

GregorCommandProcessor

public GregorCommandProcessor()

GregorCommandProcessor

public GregorCommandProcessor(MessageStoreManager storeManager,
                              ExecutorsManager executorsManager,
                              StatsManager statsManager,
                              com.taobao.gecko.service.RemotingServer remotingServer,
                              MetaConfig metaConfig,
                              IdWorker idWorker,
                              BrokerZooKeeper brokerZooKeeper,
                              ConsumerFilterManager consumerFilterManager)
方法详细信息

processSyncCommand

public void processSyncCommand(SyncCommand request,
                               SessionContext sessionContext,
                               PutCallback cb)
从接口 SyncCommandProcessor 复制的描述
处理同步命令

指定者:
接口 SyncCommandProcessor 中的 processSyncCommand


Copyright © 2010–2013. All rights reserved.