@@ -55,7 +55,7 @@ public void testRedeliverOnRecover() throws IOException, InterruptedException {
5555 assertTrue ("consumed message body not as sent" ,
5656 Arrays .equals (body , delivery .getBody ()));
5757 // Don't ack it, and get it redelivered to the same consumer
58- channel .basicRecoverAsync (false );
58+ channel .basicRecoverAsync (true );
5959 QueueingConsumer .Delivery secondDelivery = consumer .nextDelivery (5000 );
6060 assertNotNull ("timed out waiting for redelivered message" , secondDelivery );
6161 assertTrue ("consumed (redelivered) message body not as sent" ,
@@ -69,12 +69,13 @@ public void testNoRedeliveryWithAutoAck() throws IOException, InterruptedExcepti
6969 QueueingConsumer .Delivery delivery = consumer .nextDelivery ();
7070 assertTrue ("consumed message body not as sent" ,
7171 Arrays .equals (body , delivery .getBody ()));
72- channel .basicRecoverAsync (false );
72+ channel .basicRecoverAsync (true );
7373 // there's a race here between our recover finishing and the basic.get;
7474 Thread .sleep (500 );
7575 assertNull ("should be no message available" , channel .basicGet (queue , true ));
7676 }
7777
7878 // The AMQP specification under-specifies the behaviour when
79- // requeue=false. So we can't really test anything.
79+ // requeue=false. So we can't really test any scenarios for
80+ // requeue=false.
8081}
0 commit comments