|
||||||||||
上一个 下一个 | 框架 无框架 |
使用 MessageRecoverManager 的软件包 | |
---|---|
com.taobao.metamorphosis.client.extension | |
com.taobao.metamorphosis.client.extension.producer |
com.taobao.metamorphosis.client.extension 中 MessageRecoverManager 的使用 |
---|
声明为 MessageRecoverManager 的 com.taobao.metamorphosis.client.extension 中的字段 | |
---|---|
protected MessageRecoverManager |
OrderedMetaMessageSessionFactory.localMessageStorageManager
|
com.taobao.metamorphosis.client.extension.producer 中 MessageRecoverManager 的使用 |
---|
实现 MessageRecoverManager 的 com.taobao.metamorphosis.client.extension.producer 中的类 | |
---|---|
class |
LocalMessageStorageManager
消息缓存在本地磁盘,并定期或手动recover |
class |
OrderedLocalMessageStorageManager
针对顺序消息做了特殊处理的LocalMessageStorageManager |
参数类型为 MessageRecoverManager 的 com.taobao.metamorphosis.client.extension.producer 中的构造方法 | |
---|---|
OrderedMessageProducer(MetaMessageSessionFactory messageSessionFactory,
RemotingClientWrapper remotingClient,
PartitionSelector partitionSelector,
ProducerZooKeeper producerZooKeeper,
String sessionId,
MessageRecoverManager localMessageStorageManager)
|
|
||||||||||
上一个 下一个 | 框架 无框架 |