Make it so that workers only prefetch one message from the queue. Cache producers to prevent a memory leak.