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)
字段摘要 |
static org.apache.commons.logging.Log |
log
|
从类 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.