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 87b97d3 commit 6fc2d90Copy full SHA for 6fc2d90
test/src/com/rabbitmq/client/test/functional/QosTests.java
@@ -165,10 +165,12 @@ public void testSetLimitAfterConsume()
165
QueueingConsumer c = new QueueingConsumer(channel);
166
declareBindConsume(c);
167
channel.basicQos(1);
168
- fill(2);
+ fill(3);
169
//We actually only guarantee that the limit takes effect
170
//*eventually*, so this can in fact fail. It's pretty unlikely
171
//though.
172
+ Queue<Delivery> d = drain(c, 1);
173
+ ack(d, true);
174
drain(c, 1);
175
}
176
0 commit comments