CAMEL-8761: Idempotent Consumer EIP - Allow to commit when EIP scope ends
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f9ba2bae Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f9ba2bae Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f9ba2bae Branch: refs/heads/master Commit: f9ba2baeb3b5c7d780824ac374a261a8fd4e8634 Parents: b643670 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu May 14 11:48:45 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu May 14 13:28:54 2015 +0200 ---------------------------------------------------------------------- .../org/apache/camel/processor/idempotent/IdempotentConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f9ba2bae/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 6b73e63..8b47556 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 @@ -236,7 +236,7 @@ public class IdempotentConsumer extends ServiceSupport implements AsyncProcessor } // if scope is not block only then the onCompletion is invoked as part of the UoW of the Exchange } finally { - callback.done(doneSync); + callback.done(doneSync); } }
