com.taobao.metamorphosis.gregor.master
类 SamsaCommandProcessor

java.lang.Object
  com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor
      com.taobao.metamorphosis.gregor.master.SamsaCommandProcessor

所有已实现的接口：

CommandProcessor, Service

public class SamsaCommandProcessor
extends BrokerCommandProcessor

Master的broker command processor，暂不支持所有事务操作

作者：

boyan(boyan@taobao.com)

嵌套类摘要

class

SamsaCommandProcessor.SyncAppendCallback append到message store的callback

从类 com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor 继承的嵌套类/接口

BrokerCommandProcessor.StoreAppendCallback

字段摘要

从类 com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor 继承的字段

brokerZooKeeper, consumerFilterManager, executorsManager, idWorker, metaConfig, remotingServer, statsManager, storeManager

构造方法摘要

SamsaCommandProcessor()

SamsaCommandProcessor(MessageStoreManager storeManager, ExecutorsManager executorsManager, StatsManager statsManager, com.taobao.gecko.service.RemotingServer remotingServer, MetaConfig metaConfig, IdWorker idWorker, BrokerZooKeeper brokerZooKeeper, com.taobao.gecko.service.RemotingClient remotingClient, ConsumerFilterManager consumerFilterManager, String slave, int callbackThreadCount, long sendToSlaveTimeoutInMills, long checkSlaveIntervalInMills, int slaveContinuousFailureThreshold)

方法摘要

com.taobao.gecko.service.RemotingClient	getRemotingClient()
String	getSlaveUrl()
void	processPutCommand(PutCommand request, SessionContext sessionContext, PutCallback cb) 处理put请求，只有当master/slave全部写入成功的时候才认为写入成功

从类 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, 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

构造方法详细信息

SamsaCommandProcessor

public SamsaCommandProcessor()

SamsaCommandProcessor

public SamsaCommandProcessor(MessageStoreManager storeManager,
                             ExecutorsManager executorsManager,
                             StatsManager statsManager,
                             com.taobao.gecko.service.RemotingServer remotingServer,
                             MetaConfig metaConfig,
                             IdWorker idWorker,
                             BrokerZooKeeper brokerZooKeeper,
                             com.taobao.gecko.service.RemotingClient remotingClient,
                             ConsumerFilterManager consumerFilterManager,
                             String slave,
                             int callbackThreadCount,
                             long sendToSlaveTimeoutInMills,
                             long checkSlaveIntervalInMills,
                             int slaveContinuousFailureThreshold)
                      throws com.taobao.gecko.service.exception.NotifyRemotingException,
                             InterruptedException

抛出：

com.taobao.gecko.service.exception.NotifyRemotingException

InterruptedException

方法详细信息

getRemotingClient

public com.taobao.gecko.service.RemotingClient getRemotingClient()

getSlaveUrl

public String getSlaveUrl()

processPutCommand

public void processPutCommand(PutCommand request,
                              SessionContext sessionContext,
                              PutCallback cb)

处理put请求，只有当master/slave全部写入成功的时候才认为写入成功

指定者：

接口 CommandProcessor 中的 processPutCommand

覆盖：

类 BrokerCommandProcessor 中的 processPutCommand