Looked at IdempotentConsumer implementation and it looks like it needs an
IdempotentRepository that uses a String value as the idempotent key; see
line 45:

private final IdempotentRepository<String> idempotentRepository;

http://grepcode.com/file/repo1.maven.org/maven2/org.apache.camel/camel-core/2.10.6/org/apache/camel/processor/idempotent/IdempotentConsumer.java#IdempotentConsumer

So it seems like you can only use Strings for idempotent keys? Even though
IdempotentRepository interface is the following:

Interface IdempotentRepository<E>




--
View this message in context: 
http://camel.465427.n5.nabble.com/IdempotentConsumer-custom-key-tp5740789p5740799.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to