Added queue size exceeded check to aggregator