@@ -648,7 +648,8 @@ void shouldRecoverEvenIfManagementIsClosed(TestInfo info) {
648648 try (Connection connection = connection ()) {
649649 Management management = connection .management ();
650650 Management .QueueInfo queueInfo = management .queue ().exclusive (true ).declare ();
651- Publisher publisher = connection .publisherBuilder ().queue (queueInfo .name ()).build ();
651+ String q = queueInfo .name ();
652+ Publisher publisher = connection .publisherBuilder ().queue (q ).build ();
652653 Sync publishSync = TestUtils .sync ();
653654 Publisher .Callback callback =
654655 ctx -> {
@@ -661,10 +662,13 @@ void shouldRecoverEvenIfManagementIsClosed(TestInfo info) {
661662 };
662663 publisher .publish (publisher .message (), callback );
663664 assertThat (publishSync ).completes ();
665+
666+ waitAtMost (() -> management .queueInfo (q ).messageCount () == 1 );
667+
664668 Sync consumeSync = TestUtils .sync ();
665669 connection
666670 .consumerBuilder ()
667- .queue (queueInfo . name () )
671+ .queue (q )
668672 .messageHandler (
669673 (ctx , message ) -> {
670674 consumeSync .down ();
@@ -673,7 +677,7 @@ void shouldRecoverEvenIfManagementIsClosed(TestInfo info) {
673677 .build ();
674678
675679 assertThat (consumeSync ).completes ();
676- waitAtMost (() -> management .queueInfo (queueInfo . name () ).messageCount () == 0 );
680+ waitAtMost (() -> management .queueInfo (q ).messageCount () == 0 );
677681 management .close ();
678682
679683 publishSync .reset ();
@@ -682,9 +686,9 @@ void shouldRecoverEvenIfManagementIsClosed(TestInfo info) {
682686 closeConnectionAndWaitForRecovery ();
683687 publisher .publish (publisher .message (), callback );
684688 assertThat (consumeSync ).completes ();
685- assertThatThrownBy (() -> management .queueInfo (queueInfo . name () ))
689+ assertThatThrownBy (() -> management .queueInfo (q ))
686690 .isInstanceOf (AmqpResourceClosedException .class );
687- assertThat (connection .management ().queueInfo (queueInfo . name () )).isEmpty ();
691+ assertThat (connection .management ().queueInfo (q )).isEmpty ();
688692 }
689693 }
690694
0 commit comments