You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2020/07/26 22:01:38 UTC
[camel] branch master updated: Replace old groupExchanges in EIP
docs.
This is an automated email from the ASF dual-hosted git repository.
janbednar 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 e760248 Replace old groupExchanges in EIP docs.
e760248 is described below
commit e760248069556c81d57adbd7d91cdadd2d036be7
Author: Jan Bednář <ma...@janbednar.eu>
AuthorDate: Sun Jul 26 23:55:09 2020 +0200
Replace old groupExchanges in EIP docs.
---
.../src/main/docs/modules/eips/pages/aggregate-eip.adoc | 17 ++++++++---------
1 file changed, 8 insertions(+), 9 deletions(-)
diff --git a/core/camel-core-engine/src/main/docs/modules/eips/pages/aggregate-eip.adoc b/core/camel-core-engine/src/main/docs/modules/eips/pages/aggregate-eip.adoc
index 630a9302..a2f1901 100644
--- a/core/camel-core-engine/src/main/docs/modules/eips/pages/aggregate-eip.adoc
+++ b/core/camel-core-engine/src/main/docs/modules/eips/pages/aggregate-eip.adoc
@@ -365,25 +365,24 @@ To configure this from XML DSL
There is also JMX API on the aggregator which is available under the
processors node in the Camel JMX tree.
-== Using GroupedExchanges
+== Using GroupedExchangeAggregationStrategy
In the route below we group all the exchanges together using
-`groupExchanges()`:
+`GroupedExchangeAggregationStrategy`:
[source,java]
----
from("direct:start")
- // aggregate all using same expression
- .aggregate(constant(true))
+ // aggregate all using same expression and group the
+ // exchanges so we get one single exchange containing all
+ // the others
+ .aggregate(new GroupedExchangeAggregationStrategy()).constant(true)
// wait for 0.5 seconds to aggregate
- .completionTimeout(500L)
- // group the exchanges so we get one single exchange containing all the others
- .groupExchanges()
- .to("mock:result");
+ .completionTimeout(500L).to("mock:result");
----
As a result we have one outgoing `Exchange` being
-routed the `"mock:result"` endpoint. The exchange is a holder
+routed to the `"mock:result"` endpoint. The exchange is a holder
containing all the incoming Exchanges.
The output of the aggregator will then contain the exchanges grouped