Конфигурация Apache Camel RedisIdempotentRepository

Кто-нибудь смог успешно заставить RedisIdempotentRepository работать на Camel Route?

My 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 (3.0.4) и внедряется в пул соединений Redis.

Я протестировал тот же Camel Route, используя репозиторий в памяти, и сообщения были отфильтрованы.


consumer redis apache-camel idempotent
person Jeremy Deane    schedule 03.04.2016    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Проблема не в RedisIdempotentRepository. Мой экземпляр Redis был поврежден. Решение выше работает :)

person Jeremy Deane    schedule 03.04.2016