Re-enable QoS tests

Now fix is in master and 3.9.x.

Author: acogoluegnes

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

@@ -31,7 +31,6 @@
 import java.util.Map;
 import java.util.concurrent.TimeoutException;
 
-import org.junit.Ignore;
 import org.junit.Test;
 
 import com.rabbitmq.client.AMQP;
@@ -120,7 +119,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         drain(c, 2);
     }
 
-    @Ignore
     @Test public void noAckObeysLimit()
         throws IOException
     {
@@ -144,7 +142,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         drain(c2, 1);
     }
 
-    @Ignore
     @Test public void permutations()
         throws IOException
     {
@@ -162,7 +159,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         }
     }
 
-    @Ignore
     @Test public void fairness()
         throws IOException
     {
@@ -192,7 +188,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
 
     }
 
-    @Ignore
     @Test public void singleChannelAndQueueFairness()
         throws IOException
     {
@@ -242,7 +237,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         assertTrue(counts.get("c2").intValue() > 0);
     }
 
-    @Ignore
     @Test public void consumerLifecycle()
         throws IOException
     {
@@ -264,7 +258,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         channel.queueDelete(queue);
     }
 
-    @Ignore
     @Test public void setLimitAfterConsume()
         throws IOException
     {
@@ -289,7 +282,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         drain(c, 1);
     }
 
-    @Ignore
     @Test public void limitDecrease()
         throws IOException
     {
@@ -310,7 +302,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         drain(c, 2);
     }
 
-    @Ignore
     @Test public void limitingMultipleChannels()
         throws IOException
     {
@@ -347,7 +338,6 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
         drain(c, 1);
     }
 
-    @Ignore
     @Test public void recoverReducesLimit() throws Exception {
         channel.basicQos(2, true);
         QueueingConsumer c = new QueueingConsumer(channel);