make AccumulatorAggregator a interface, change existing impl to BlockingAccumulatorAggregator