Skip to content

Commit 6ae0713

Browse files
author
Emile Joubert
committed
Check redeliveryflag after recover in purge test
1 parent e242179 commit 6ae0713

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,7 @@ public void testUnackedPurge() throws IOException {
7575
channel.basicPublish(binding.x, binding.k, null, payload);
7676

7777
GetResponse response = channel.basicGet(binding.q, false);
78+
assertFalse(response.getEnvelope().isRedeliver());
7879
assertNotNull("The response SHOULD NOT BE null", response);
7980

8081
// If we purge the queue the unacked message should still be there on
@@ -85,6 +86,7 @@ public void testUnackedPurge() throws IOException {
8586

8687
channel.basicRecoverAsync(true);
8788
response = channel.basicGet(binding.q, false);
89+
assertTrue(response.getEnvelope().isRedeliver());
8890
assertNotNull("The response SHOULD NOT BE null", response);
8991

9092
// If we recover then purge the message should go away

0 commit comments

Comments
 (0)