File tree Expand file tree Collapse file tree 1 file changed +13
-0
lines changed
test/src/com/rabbitmq/client/test/functional Expand file tree Collapse file tree 1 file changed +13
-0
lines changed Original file line number Diff line number Diff line change 4747import com .rabbitmq .client .Channel ;
4848import com .rabbitmq .client .GetResponse ;
4949import com .rabbitmq .client .QueueingConsumer ;
50+ import com .rabbitmq .client .ShutdownSignalException ;
5051import com .rabbitmq .client .QueueingConsumer .Delivery ;
5152
5253import com .rabbitmq .client .AMQP .BasicProperties ;
@@ -347,6 +348,18 @@ public void testLimitingMultipleChannels()
347348 ch2 .close ();
348349 }
349350
351+ public void testLimitInheritsUnackedCount () throws IOException , ShutdownSignalException , InterruptedException {
352+ QueueingConsumer c = new QueueingConsumer (channel );
353+ channel .basicQos (1 );
354+ declareBindConsume (c );
355+ fill (4 );
356+ drain (c , 1 );
357+ channel .basicQos (2 );
358+ Queue <Delivery > acks = drain (c , 1 );
359+ ackDelivery (acks .remove (), true );
360+ drain (c , 2 );
361+ }
362+
350363 protected void runLimitTests (int limit ,
351364 boolean multiAck ,
352365 boolean txMode ,
You can’t perform that action at this time.
0 commit comments