2016-04-03 1 views
3

Est-ce que quelqu'un a réussi à faire fonctionner RedisIdempotentRepository dans une Route Camel?Apache Camel RedisIdempotentRepository Configuration

Mon parcours Camel est construit en utilisant Java 8+, Apache Camel (2.17.1) et Spring Boot (1.3.3.RELEASE). Les charges Route Camel et de traitement des messages, mais ne filtrent pas les doublons:

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

Le RedisTemplate est connecté à un serveur Redis locale (3.0.4) et est injecté avec une connexion Redis Pool.

J'ai testé la même route Camel à l'aide du référentiel en mémoire et les messages ont été filtrés.

Répondre

0

RedisIdempotentRepository n'était pas le problème. Mon instance Redis était corrompue. La solution ci-dessus fonctionne :)