Fixed bug in WorkerPool where it would consume messages before they were published in the multi-producer scenario