The RoundRobin test as it stood only checked that an equal number of messages were sent to each consumer, not that the consumers were roundrobined.

Author: Matthew Sackman

test/src/com/rabbitmq/client/test/functional/QosTests.java

@@ -221,13 +221,18 @@ public void testRoundRobin()
 
         final Map<String, Integer> counts =
             Collections.synchronizedMap(new HashMap<String, Integer>());
+        final String [] nextTag = new String[] { null };
 
         QueueingConsumer c = new QueueingConsumer(channel) {
                 @Override public void handleDelivery(String consumerTag,
                                                      Envelope envelope,
                                                      AMQP.BasicProperties properties,
                                                      byte[] body)
                     throws IOException {
+                    String otherConsumerTag = "c1".equals(consumerTag) ? "c2" : "c1";
+                    if (null != nextTag[0])
+                        assertEquals(consumerTag, nextTag[0]);
+                    nextTag[0] = otherConsumerTag;
                     counts.put(consumerTag, counts.get(consumerTag) + 1);
                     super.handleDelivery(consumerTag, envelope,
                                          properties, body);