You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/03/03 19:36:36 UTC
[13/14] camel git commit: CAMEL-10934: Idempotent Consumer EIP -
Should prepare idempotent repository better
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 <da...@apache.org>
Authored: Fri Mar 3 20:16:21 2017 +0100
Committer: Claus Ibsen <da...@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 {