camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [13/14] camel git commit: CAMEL-10934: Idempotent Consumer EIP - Should prepare idempotent repository better
Date Fri, 03 Mar 2017 19:36:36 GMT
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 <davsclaus@apache.org>
Authored: Fri Mar 3 20:16:21 2017 +0100
Committer: Claus Ibsen <davsclaus@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 {


Mime
View raw message