[activemq-artemis] branch master updated: NO-JIRA Fixing Stomp Tests after QueueManager change

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[activemq-artemis] branch master updated: NO-JIRA Fixing Stomp Tests after QueueManager change

clebertsuconic-2
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 757d38f  NO-JIRA Fixing Stomp Tests after QueueManager change
757d38f is described below

commit 757d38f53c6a349854fe1715b6d10920bccd92ad
Author: Clebert Suconic <[hidden email]>
AuthorDate: Fri Jan 10 00:08:11 2020 -0500

    NO-JIRA Fixing Stomp Tests after QueueManager change
---
 .../apache/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 73d74c0..71e596e 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