Updated Branches:
  refs/heads/camel-2.11.x 1fa36db5b -> eb0238c1e
  refs/heads/master a91083b34 -> e2b22608c


On completion should not double wrap UoW


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/eb0238c1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/eb0238c1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/eb0238c1

Branch: refs/heads/camel-2.11.x
Commit: eb0238c1ec10d17c61510deff488fa15b82012be
Parents: 1fa36db
Author: Claus Ibsen <[email protected]>
Authored: Fri May 17 17:03:34 2013 +0200
Committer: Claus Ibsen <[email protected]>
Committed: Fri May 17 17:03:34 2013 +0200

----------------------------------------------------------------------
 .../camel/processor/OnCompletionProcessor.java     |    3 +--
 1 files changed, 1 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/eb0238c1/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
----------------------------------------------------------------------
diff --git 
a/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
 
b/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
index f0f60cb..d374db0 100644
--- 
a/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
+++ 
b/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
@@ -56,8 +56,7 @@ public class OnCompletionProcessor extends ServiceSupport 
implements Processor,
         notNull(camelContext, "camelContext");
         notNull(processor, "processor");
         this.camelContext = camelContext;
-        // wrap processor in UnitOfWork so what we send out runs in a UoW
-        this.processor = new UnitOfWorkProcessor(processor);
+        this.processor = processor;
         this.executorService = executorService;
         this.shutdownExecutorService = shutdownExecutorService;
         this.onCompleteOnly = onCompleteOnly;

Reply via email to