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.
2 parents 18adc5d + 13b30d5 commit f7eb76dCopy full SHA for f7eb76d
test/src/com/rabbitmq/client/test/functional/QosTests.java
@@ -347,6 +347,18 @@ public void testLimitingMultipleChannels()
347
ch2.close();
348
}
349
350
+ public void testLimitInheritsUnackedCount()
351
+ throws IOException
352
+ {
353
+ QueueingConsumer c = new QueueingConsumer(channel);
354
+ declareBindConsume(c);
355
+ fill(1);
356
+ drain(c, 1);
357
+ channel.basicQos(2);
358
+ fill(2);
359
360
+ }
361
+
362
protected void runLimitTests(int limit,
363
boolean multiAck,
364
boolean txMode,
0 commit comments