nuke channel.flow{active=true} tests & usage

Author: rade

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

@@ -344,43 +344,6 @@ public void testLimitInheritsUnackedCount()
         drain(c, 1);
     }
 
-    public void testFlow() throws IOException
-    {
-        QueueingConsumer c = new QueueingConsumer(channel);
-        declareBindConsume(c);
-        fill(1);
-        drain(c, 1);
-        channel.flow(false);
-        fill(1);
-        drain(c, 0);
-        channel.flow(true);
-        drain(c, 1);
-    }
-
-    public void testLimitAndFlow() throws IOException
-    {
-        channel.basicQos(1);
-        QueueingConsumer c = new QueueingConsumer(channel);
-        declareBindConsume(c);
-        channel.flow(false);
-        fill(3);
-        drain(c, 0);
-        channel.flow(true);
-        ack(drain(c, 1), false);
-        drain(c, 1);
-        channel.basicQos(0);
-        drain(c, 1);
-    }
-
-    public void testNoConsumers() throws Exception {
-        String q = declareBind(channel);
-        fill(1);
-        channel.flow(false);
-        QueueingConsumer c = new QueueingConsumer(channel);
-        channel.basicConsume(q, c);
-        drain(c, 0);
-    }
-
     public void testRecoverReducesLimit() throws Exception {
         channel.basicQos(2);
         QueueingConsumer c = new QueueingConsumer(channel);

test/src/com/rabbitmq/client/test/performance/QosScaling.java

@@ -129,9 +129,7 @@ public long run() throws IOException {
         channel.basicQos(1);
         QueueingConsumer consumer = new QueueingConsumer(channel);
         try {
-            channel.flow(false);
             publish(consume(consumer));
-            channel.flow(true);
             return drain(consumer);
         } finally {
             connection.abort();