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 2021/03/19 14:03:43 UTC
[camel] 01/02: CAMEL-16295: fix aggregation when in transacted route
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit e5824f6aecee646e5eb47b87780b6824d0456962
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Mar 19 14:59:33 2021 +0100
CAMEL-16295: fix aggregation when in transacted route
---
.../main/java/org/apache/camel/processor/MulticastProcessor.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
index 75e2a90..265bf2f 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
@@ -596,11 +596,9 @@ public class MulticastProcessor extends AsyncProcessorSupport
});
// next step
- if (hasNext && !isParallelProcessing()) {
- return true;
- } else {
- return false;
- }
+ boolean next = hasNext && !isParallelProcessing();
+ LOG.trace("Run next: {}", next);
+ return next;
}
}