activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject activemq-artemis git commit: ARTEMIS-1287 Simple test fix SimpleOpenWireTest
Date Thu, 13 Jul 2017 20:23:10 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master cc6ca36c5 -> ac6420038


ARTEMIS-1287 Simple test fix SimpleOpenWireTest


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ac642003
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ac642003
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ac642003

Branch: refs/heads/master
Commit: ac6420038f4250ba28c89e0dbee0ca596ee5dc9a
Parents: cc6ca36
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Thu Jul 13 16:13:13 2017 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Thu Jul 13 16:16:00 2017 -0400

----------------------------------------------------------------------
 .../artemis/tests/integration/openwire/SimpleOpenWireTest.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ac642003/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
index fcd85ef..f0fc8a6 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
@@ -51,6 +51,7 @@ import java.util.ArrayList;
 import java.util.Collection;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
@@ -1478,7 +1479,7 @@ public class SimpleOpenWireTest extends BasicOpenWireTest {
          TopicSession topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
          Topic notificationsTopic = topicSession.createTopic("activemq.notifications");
          TopicSubscriber subscriber = topicSession.createSubscriber(notificationsTopic);
-         List<Message> receivedMessages = new ArrayList<>();
+         List<Message> receivedMessages = new CopyOnWriteArrayList<>();
          subscriber.setMessageListener(receivedMessages::add);
          topicConnection.start();
 


Mime
View raw message