How to Implement Round‑Robin and Fair Dispatch with RabbitMQ Work Queues

When using a simple queue, producers can publish messages quickly while consumers may take longer to process each message, causing backlog and under‑utilization of workers. Creating multiple consumers on the same queue lets them compete for messages, enabling parallel processing and better scalability.

Round‑Robin (Default) Distribution

In the default round‑robin mode, each consumer receives messages in turn regardless of processing speed. The example includes:

Producer that declares test_queue_work and publishes 50 messages.

Consumer 1 ( Recv1) that simulates a 1‑second task.

Consumer 2 ( Recv2) that simulates a 2‑second task.

public class Send { ... }

public class Recv1 { ... }

public class Recv2 { ... }

Test results show that each consumer receives alternating messages (odd/even), so the faster consumer does not get more work; the workload is split evenly regardless of processing time.

Fair Dispatch (Prefetch = 1)

To avoid the imbalance where a slow consumer holds up the queue, enable basicQos(prefetchCount=1) and switch to manual acknowledgments. This ensures RabbitMQ sends only one un‑acknowledged message to a consumer at a time.

Producer now sets channel.basicQos(1) before publishing.

Consumers disable auto‑ack ( autoAck = false) and call channel.basicAck after processing.

channel.basicQos(1); // limit to one un‑acked message per consumer

boolean autoAck = false;
channel.basicConsume(QUEUE_NAME, autoAck, consumer);
channel.basicAck(envelope.getDeliveryTag(), false);

With this configuration, the faster consumer processes more messages because it acknowledges quickly and receives the next message, while the slower consumer handles fewer tasks.

Key Takeaways

Multiple consumers on a single queue enable parallel processing.

Round‑robin distributes messages evenly but ignores consumer speed.

Fair dispatch with basicQos(1) and manual acks balances load based on actual processing time.

Always close channels and connections after use.