We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e52d898 commit 1db8411Copy full SHA for 1db8411
test/src/com/rabbitmq/client/test/functional/QosTests.java
@@ -350,14 +350,12 @@ public void testLimitingMultipleChannels()
350
351
public void testLimitInheritsUnackedCount() throws IOException, ShutdownSignalException, InterruptedException {
352
QueueingConsumer c = new QueueingConsumer(channel);
353
- channel.basicQos(1);
354
declareBindConsume(c);
355
- fill(4);
+ fill(1);
356
drain(c, 1);
357
channel.basicQos(2);
358
- Queue<Delivery> acks = drain(c, 1);
359
- ackDelivery(acks.remove(), true);
360
- drain(c, 2);
+ fill(2);
+ drain(c, 1);
361
}
362
363
protected void runLimitTests(int limit,
0 commit comments