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的连接池。
我使用内存存储库测试了相同的骆驼路由,并且这些消息被过滤掉了。