Skip to content

Commit b3bd4c7

Browse files
author
Matthew Sackman
committed
Added test
1 parent 3c96aef commit b3bd4c7

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

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

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -368,6 +368,16 @@ public void testNoConsumers() throws Exception {
368368
drain(c, 0);
369369
}
370370

371+
public void testRecoverReducesLimit() throws Exception {
372+
channel.basicQos(2);
373+
QueueingConsumer c = new QueueingConsumer(channel);
374+
declareBindConsume(c);
375+
fill(3);
376+
drain(c, 2);
377+
channel.basicRecover(true);
378+
drain(c, 2);
379+
}
380+
371381
protected void runLimitTests(int limit,
372382
boolean multiAck,
373383
boolean txMode,

0 commit comments

Comments
 (0)