【问题标题】:Apache Camel RedisIdempotentRepository ConfigurationApache Camel RedisIdempotentRepository 配置
【发布时间】: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


    【解决方案1】:

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2018-11-16
      • 1970-01-01
      • 2022-08-17
      • 1970-01-01
      • 2012-07-20
      • 1970-01-01
      相关资源
      最近更新 更多