diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/PagingFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/PagingFailoverTest.java index c3ce8e9870..477c04e4f5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/PagingFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/PagingFailoverTest.java @@ -183,6 +183,8 @@ public class PagingFailoverTest extends FailoverTestBase { session.close(); + Wait.assertTrue(() -> backupServer.getServer().locateQueue(ADDRESS) != null, 15_000, 100); + Queue queue = backupServer.getServer().locateQueue(ADDRESS); Wait.assertFalse( () -> {