类 com.taobao.metamorphosis.server.store.MessageStoreManager
的使用

使用 MessageStoreManager 的软件包

com.taobao.metamorphosis.gregor.master
com.taobao.metamorphosis.gregor.slave
com.taobao.metamorphosis.metaslave
com.taobao.metamorphosis.server.assembly
com.taobao.metamorphosis.server.stats
com.taobao.metamorphosis.server.transaction.store

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

参数类型为 MessageStoreManager 的 com.taobao.metamorphosis.gregor.master 中的构造方法

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.metamorphosis.gregor.slave 中 MessageStoreManager 的使用

参数类型为 MessageStoreManager 的 com.taobao.metamorphosis.gregor.slave 中的构造方法

GregorCommandProcessor(MessageStoreManager storeManager, ExecutorsManager executorsManager, StatsManager statsManager, com.taobao.gecko.service.RemotingServer remotingServer, MetaConfig metaConfig, IdWorker idWorker, BrokerZooKeeper brokerZooKeeper, ConsumerFilterManager consumerFilterManager)

com.taobao.metamorphosis.metaslave 中 MessageStoreManager 的使用

参数类型为 MessageStoreManager 的 com.taobao.metamorphosis.metaslave 中的构造方法

MetaSlaveListener(BrokerZooKeeper brokerZooKeeper, MessageStoreManager storeManager, SlaveStatsManager slaveStatsManager)

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

声明为 MessageStoreManager 的 com.taobao.metamorphosis.server.assembly 中的字段

protected MessageStoreManager

BrokerCommandProcessor.storeManager

返回 MessageStoreManager 的 com.taobao.metamorphosis.server.assembly 中的方法

MessageStoreManager	MetaMorphosisBroker.getStoreManager()
MessageStoreManager	BrokerCommandProcessor.getStoreManager()

参数类型为 MessageStoreManager 的 com.taobao.metamorphosis.server.assembly 中的方法

void	BrokerCommandProcessor.setStoreManager(MessageStoreManager storeManager)

参数类型为 MessageStoreManager 的 com.taobao.metamorphosis.server.assembly 中的构造方法

BrokerCommandProcessor(MessageStoreManager storeManager, ExecutorsManager executorsManager, StatsManager statsManager, com.taobao.gecko.service.RemotingServer remotingServer, MetaConfig metaConfig, IdWorker idWorker, BrokerZooKeeper brokerZooKeeper, ConsumerFilterManager consumerFilterManager)

TransactionalCommandProcessor(MetaConfig metaConfig, MessageStoreManager storeManager, IdWorker idWorker, CommandProcessor next, TransactionStore transactionStore, StatsManager stasManager)

com.taobao.metamorphosis.server.stats 中 MessageStoreManager 的使用

参数类型为 MessageStoreManager 的 com.taobao.metamorphosis.server.stats 中的构造方法

StatsManager(MetaConfig metaConfig, MessageStoreManager messageStoreManager, com.taobao.gecko.service.RemotingServer remotingServer)

com.taobao.metamorphosis.server.transaction.store 中 MessageStoreManager 的使用

参数类型为 MessageStoreManager 的 com.taobao.metamorphosis.server.transaction.store 中的构造方法

JournalStore(String path, MessageStoreManager storeManager, JournalTransactionStore transactionStore, int maxCheckpoints, int flushTxLogAtCommit)

JournalTransactionStore(String dataPath, MessageStoreManager storeManager, MetaConfig metaConfig)