接口 com.taobao.metamorphosis.client.extension.producer.MessageRecoverManager
的使用

使用 MessageRecoverManager 的软件包
com.taobao.metamorphosis.client.extension   
com.taobao.metamorphosis.client.extension.producer   
 

com.taobao.metamorphosis.client.extensionMessageRecoverManager 的使用
 

声明为 MessageRecoverManagercom.taobao.metamorphosis.client.extension 中的字段
protected  MessageRecoverManager OrderedMetaMessageSessionFactory.localMessageStorageManager
           
 

com.taobao.metamorphosis.client.extension.producerMessageRecoverManager 的使用
 

实现 MessageRecoverManagercom.taobao.metamorphosis.client.extension.producer 中的类
 class LocalMessageStorageManager
          消息缓存在本地磁盘,并定期或手动recover
 class OrderedLocalMessageStorageManager
          针对顺序消息做了特殊处理的LocalMessageStorageManager
 

参数类型为 MessageRecoverManagercom.taobao.metamorphosis.client.extension.producer 中的构造方法
OrderedMessageProducer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, PartitionSelector partitionSelector, ProducerZooKeeper producerZooKeeper, String sessionId, MessageRecoverManager localMessageStorageManager)
           
 



Copyright © 2010–2013. All rights reserved.