接口 com.taobao.metamorphosis.client.consumer.MessageIdCache
的使用

使用 MessageIdCache 的软件包
com.taobao.metamorphosis.client.consumer   
 

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

实现 MessageIdCachecom.taobao.metamorphosis.client.consumer 中的类
 class ConcurrentLRUHashMap
          Concurrent LRU map
 

参数类型为 MessageIdCachecom.taobao.metamorphosis.client.consumer 中的方法
static void SimpleFetchManager.setMessageIdCache(MessageIdCache newCache)
          Set new message id cache to prevent duplicated messages for the same consumer group.
 



Copyright © 2010–2013. All rights reserved.