Add fix size queue and parallel consumers/producers.