2016-04-03 151 views
3

任何人都可以成功获取RedisIdempotentRepository在骆驼路径中工作吗?Apache Camel RedisIdempotentRepository配置

我的骆驼路线是使用Java 8+,Apache Camel(2.17.1)和Spring Boot(1.3.3.RELEASE)构建的。骆驼路线负荷和处理消息,但不会过滤掉重复:

from("activemq:generic.order"). 
idempotentConsumer(header("uniqueId"), 
RedisIdempotentRepository.redisIdempotentRepository(redisTemplate,"camel-repo")). 
to("activemq:unique.order"); 

的RedisTemplate被连接到本地Redis的服务器(3.0.4)和注射用Redis的连接池。

我使用内存存储库测试了相同的骆驼路由,并且这些消息被过滤掉了。

回答

0

RedisIdempotentRepository不是问题。我的Redis实例已损坏。上述解决方案:)