private Exchange aggregationStrategy()

in aggregate-dist/src/main/java/org/apache/camel/example/Application.java [168:178]

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

    private Exchange aggregationStrategy(Exchange oldExchange, Exchange newExchange) {
        if (oldExchange == null) {
            return newExchange;
        }
        String body = oldExchange.getIn().getBody(String.class) + "."
                + newExchange.getIn().getBody(String.class);
        oldExchange.getIn().setBody(body);
        LOG.trace("Queue: {}", inputQueue);
        LOG.trace("Aggregation: {}", oldExchange.getIn().getBody());
        return oldExchange;
    }