2016-04-03 2 views
3

Кто-нибудь смог успешно получить RedisIdempotentRepository, работающий на верблюжьем пути?Apache Camel RedisIdempotentRepository Конфигурация

My Camel Route построен с использованием Java 8+, Apache Camel (2.17.1) и Spring Boot (1.3.3.RELEASE). Нагрузки Camel маршрута и обрабатывают сообщения, но не отфильтровывать дубликаты:

from("activemq:generic.order"). 
idempotentConsumer(header("uniqueId"), 
RedisIdempotentRepository.redisIdempotentRepository(redisTemplate,"camel-repo")). 
to("activemq:unique.order"); 

RedisTemplate подключен к локальному Redis Server (3.0.4) и вводит с помощью Redis пула соединений.

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

ответ

0

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

Смежные вопросы