Skip to content

Commit 928693f

Browse files
committed
add asserts to test
1 parent ecdbd20 commit 928693f

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -567,8 +567,11 @@ public void queueRecovered(String oldName, String newName) {
567567
try {
568568
// now delete it using the delegate so AutorecoveringConnection and AutorecoveringChannel are not aware of it
569569
((AutorecoveringChannel)channel).getDelegate().queueDelete(q);
570+
assertNotNull(((AutorecoveringConnection)connection).getRecordedQueues().get(q));
570571
// exclude the queue from recovery
571572
((AutorecoveringConnection)connection).excludeQueueFromRecovery(q, true);
573+
// verify its not there
574+
assertNull(((AutorecoveringConnection)connection).getRecordedQueues().get(q));
572575
// reconnect
573576
closeAndWaitForRecovery();
574577
expectChannelRecovery(channel);

0 commit comments

Comments
 (0)