Skip to content

Commit

Permalink
Disable global QoS temporarily
Browse files Browse the repository at this point in the history
Because of a regression in 3.9.x.

References rabbitmq/rabbitmq-server#3230

(cherry picked from commit 559c4cb)
  • Loading branch information
acogoluegnes committed Jul 26, 2021
1 parent 5cb9461 commit 02ccdc2
Showing 1 changed file with 10 additions and 0 deletions.
10 changes: 10 additions & 0 deletions src/test/java/com/rabbitmq/client/test/functional/QosTests.java
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@
import java.util.Map;
import java.util.concurrent.TimeoutException;

import org.junit.Ignore;
import org.junit.Test;

import com.rabbitmq.client.AMQP;
Expand Down Expand Up @@ -119,6 +120,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
drain(c, 2);
}

@Ignore
@Test public void noAckObeysLimit()
throws IOException
{
Expand All @@ -142,6 +144,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
drain(c2, 1);
}

@Ignore
@Test public void permutations()
throws IOException
{
Expand All @@ -159,6 +162,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
}
}

@Ignore
@Test public void fairness()
throws IOException
{
Expand Down Expand Up @@ -188,6 +192,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)

}

@Ignore
@Test public void singleChannelAndQueueFairness()
throws IOException
{
Expand Down Expand Up @@ -237,6 +242,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
assertTrue(counts.get("c2").intValue() > 0);
}

@Ignore
@Test public void consumerLifecycle()
throws IOException
{
Expand All @@ -258,6 +264,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
channel.queueDelete(queue);
}

@Ignore
@Test public void setLimitAfterConsume()
throws IOException
{
Expand All @@ -282,6 +289,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
drain(c, 1);
}

@Ignore
@Test public void limitDecrease()
throws IOException
{
Expand All @@ -302,6 +310,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
drain(c, 2);
}

@Ignore
@Test public void limitingMultipleChannels()
throws IOException
{
Expand Down Expand Up @@ -338,6 +347,7 @@ 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);
Expand Down

0 comments on commit 02ccdc2

Please sign in to comment.