NO-JIRA Fixing Stomp Tests after QueueManager change

This commit is contained in:
Clebert Suconic 2020-01-10 00:08:11 -05:00
parent d6331b01f4
commit 757d38f53c
1 changed files with 3 additions and 3 deletions

View File

@ -1231,7 +1231,7 @@ public class StompTest extends StompTestBase {
unsubscribe(conn, null, getQueuePrefix() + nonExistentQueue, true, false); 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)); sendJmsMessage(getName(), ActiveMQJMSClient.createQueue(nonExistentQueue));
@ -1341,7 +1341,7 @@ public class StompTest extends StompTestBase {
conn.disconnect(); conn.disconnect();
Thread.sleep(500); Thread.sleep(500);
assertNull(server.locateQueue(SimpleString.toSimpleString("myclientid." + getName()))); Wait.assertTrue(() -> server.locateQueue(SimpleString.toSimpleString("myclientid." + getName())) == null);
} }
@Test @Test
@ -1395,7 +1395,7 @@ public class StompTest extends StompTestBase {
conn.disconnect(); conn.disconnect();
Thread.sleep(500); Thread.sleep(500);
assertNull(server.locateQueue(SimpleString.toSimpleString("myclientid." + getName()))); Wait.assertTrue(() -> server.locateQueue(SimpleString.toSimpleString("myclientid." + getName())) == null);
} }
@Test @Test