【发布时间】:2016-04-03 19:07:58
【问题描述】:
有没有人能够成功地让 RedisIdempotentRepository 在骆驼路线中工作?
我的 Camel Route 是使用 Java 8+、Apache Camel (2.17.1) 和 Spring Boot (1.3.3.RELEASE) 构建的。 Camel Route 会加载和处理消息,但不会过滤掉重复消息:
from("activemq:generic.order").
idempotentConsumer(header("uniqueId"),
RedisIdempotentRepository.redisIdempotentRepository(redisTemplate,"camel-repo")).
to("activemq:unique.order");
RedisTemplate 连接到本地 Redis Server(3.0.4) 并注入 Redis 连接池。
我使用内存存储库测试了相同的 Camel Route,消息被过滤掉了。
【问题讨论】:
标签: redis apache-camel consumer idempotent