public Exchange aggregate()

in cafe/src/main/java/org/apache/camel/example/cafe/stuff/CafeAggregationStrategy.java [30:40]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    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;
    }