class AggregatorAdapter extends AdapterSupport implements AggregationStrategy {

    @Override
    public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
        Object newInput = adaptAggregationInput(newExchange);
        Object oldInput = adaptInput(oldExchange);
        Object params = adaptParams(oldExchange);
        if (params == null) {
            doAggregate(oldExchange, oldInput, newInput, (Object[])null);
        } else if (params.getClass().isArray()) {
            doAggregate(oldExchange, oldInput, newInput, (Object[])params);
        } else {
            doAggregate(oldExchange, oldInput, newInput, params);
        }
        return oldExchange;
    }

    public  AggregatorAdapter(Aggregator aggregator);

}