From 757d38f53c6a349854fe1715b6d10920bccd92ad Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Fri, 10 Jan 2020 00:08:11 -0500 Subject: [PATCH] NO-JIRA Fixing Stomp Tests after QueueManager change --- .../activemq/artemis/tests/integration/stomp/StompTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java index 73d74c094a..71e596ee1d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java @@ -1231,7 +1231,7 @@ public class StompTest extends StompTestBase { unsubscribe(conn, null, getQueuePrefix() + nonExistentQueue, true, false); - assertNull(server.getPostOffice().getBinding(new SimpleString(nonExistentQueue))); + Wait.assertTrue(() -> server.getPostOffice().getBinding(new SimpleString(nonExistentQueue)) == null); sendJmsMessage(getName(), ActiveMQJMSClient.createQueue(nonExistentQueue)); @@ -1341,7 +1341,7 @@ public class StompTest extends StompTestBase { conn.disconnect(); Thread.sleep(500); - assertNull(server.locateQueue(SimpleString.toSimpleString("myclientid." + getName()))); + Wait.assertTrue(() -> server.locateQueue(SimpleString.toSimpleString("myclientid." + getName())) == null); } @Test @@ -1395,7 +1395,7 @@ public class StompTest extends StompTestBase { conn.disconnect(); Thread.sleep(500); - assertNull(server.locateQueue(SimpleString.toSimpleString("myclientid." + getName()))); + Wait.assertTrue(() -> server.locateQueue(SimpleString.toSimpleString("myclientid." + getName())) == null); } @Test