cafe-endpointdsl/src/main/java/org/apache/camel/example/cafe/stuff/CafeAggregationStrategy.java [26:39]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class CafeAggregationStrategy implements AggregationStrategy {

    @Override
    @SuppressWarnings("unchecked")
    public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
        List<Drink> drinks;
        if (oldExchange == null) {
            drinks = new ArrayList<>();           
        } else {
            drinks = (List<Drink>) oldExchange.getIn().getBody();
        }
        drinks.add(newExchange.getIn().getBody(Drink.class));
        newExchange.getIn().setBody(drinks);
        return newExchange;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



cafe/src/main/java/org/apache/camel/example/cafe/stuff/CafeAggregationStrategy.java [26:39]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class CafeAggregationStrategy implements AggregationStrategy {

    @Override
    @SuppressWarnings("unchecked")
    public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
        List<Drink> drinks;
        if (oldExchange == null) {
            drinks = new ArrayList<>();           
        } else {
            drinks = (List<Drink>) oldExchange.getIn().getBody();
        }
        drinks.add(newExchange.getIn().getBody(Drink.class));
        newExchange.getIn().setBody(drinks);
        return newExchange;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -