initial version of an accumulator aggregator based on queueing