redis - Apache Camel RedisIdempotentRepository 配置

标签 redis apache-camel consumer idempotent

有没有人能够成功地让 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/

相关文章:

amazon-web-services - Redis:没有多可用区的复制是否有意义?

python - 在redis中保存unicode但获取错误

java - 将 activemq 消耗到日志中,但将消息保留在队列中

java - Apache Camel : What is the best way to reuse Camel routes from other routes?

twitter - Camel 中的动态来源(URI)

java - 为什么我的 `Stream` 在运行时被关闭?

java - WRONGTYPE 针对持有错误类型值的键的操作

客户端。如何分离读/写操作?

java - 如果在路由完成后未能移动文件,让 Apache Camel 停止重试

ssl - Apache camel - 带 SSL 的 MQTT