有没有人能够成功地让 RedisIdempotentRepository 在 Camel Route 中工作?
我的 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),并注入(inject)了 Redis 连接池。
我使用内存存储库测试了相同的 Camel Route,消息被过滤掉了。
最佳答案
RedisIdempotentRepository 不是问题所在。我的 Redis 实例已损坏。上面的解决方案有效:)
关于redis - Apache Camel RedisIdempotentRepository 配置,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36389873/