This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 69e0bce Fix aggregation tests
69e0bce is described below
commit 69e0bce83922e1a5808bfca71cdd349780fbae17
Author: Guillaume Nodet <[email protected]>
AuthorDate: Mon Jan 14 14:23:22 2019 +0100
Fix aggregation tests
---
.../java/org/apache/camel/processor/aggregate/AggregateProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
index d4fd9de..2bc5fca 100644
---
a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
+++
b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
@@ -770,7 +770,7 @@ public class AggregateProcessor extends
AsyncProcessorSupport implements Navigat
// send this exchange
// the call to schedule last if needed to ensure in-order processing
of the aggregates
- executorService.submit(() -> ReactiveHelper.scheduleLast(() ->
processor.process(exchange, done -> {
+ executorService.submit(() -> ReactiveHelper.scheduleSync(() ->
processor.process(exchange, done -> {
// log exception if there was a problem
if (exchange.getException() != null) {
// if there was an exception then let the exception handler
handle it
