corrected the test. This fails without the fix and passes with the fix. declareBindConsume creates a new private queue which I hadn't realised.

Author: Matthew Sackman

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

@@ -138,18 +138,21 @@ public void testNoAckObeysLimit()
         channel.basicQos(1);
         QueueingConsumer c1 = new QueueingConsumer(channel);
         declareBindConsume(channel, c1, false);
-        fill(2);
+        fill(1);
         QueueingConsumer c2 = new QueueingConsumer(channel);
         declareBindConsume(channel, c2, true);
+        fill(1);
         try {
             Delivery d = c2.nextDelivery(1000);
             assertNull(d);
         } catch (InterruptedException ie) {
             fail("interrupted");
         }
         Queue<Delivery> d = drain(c1, 1);
+        ack(d, false); // must ack before the next one appears
+        d = drain(c1, 1);
         ack(d, false);
-        // we have no guarantees about where the other message has gone
+        drain(c2, 1);
     }
 
     public void testPermutations()