Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-06 10:09:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA fix another OpenWire race

Browse Source
This commit is contained in:
Justin Bertram 2018-05-07 15:25:23 -05:00 committed by Clebert Suconic
parent 88b1371e98
commit 67964facf0
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
View File

@ -729,6 +729,9 @@ public class SimpleOpenWireTest extends BasicOpenWireTest {
TopicSession newTopicSession = newConn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
TopicPublisher publisher = newTopicSession.createPublisher(tempTopic);
// need to wait here because the ActiveMQ client's temp destination map is updated asynchronously, not waiting can introduce a race
assertTrue(Wait.waitFor(() -> newConn.activeTempDestinations.size() == 1, 2000, 100));
TextMessage msg = newTopicSession.createTextMessage("Test Message");
publisher.publish(msg);