CAMEL-10934: Idempotent Consumer EIP - Should prepare idempotent repository better
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/992af111 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/992af111 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/992af111 Branch: refs/heads/master Commit: 992af111e2b926a2662044ade320e291b5ed6a70 Parents: 96cc1ce Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Mar 3 20:16:21 2017 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Mar 3 20:16:21 2017 +0100 ---------------------------------------------------------------------- .../org/apache/camel/processor/idempotent/IdempotentConsumer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/992af111/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java index 46521aa..742a6e6 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java +++ b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java @@ -204,10 +204,11 @@ public class IdempotentConsumer extends ServiceSupport implements CamelContextAw // ------------------------------------------------------------------------- protected void doStart() throws Exception { - ServiceHelper.startServices(processor, idempotentRepository); + // must add before start so it will have CamelContext injected first if (!camelContext.hasService(idempotentRepository)) { camelContext.addService(idempotentRepository); } + ServiceHelper.startServices(processor, idempotentRepository); } protected void doStop() throws Exception {
