activemq-artemis git commit: ARTEMIS-1287 Simple test fix SimpleOpenWireTest

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

activemq-artemis git commit: ARTEMIS-1287 Simple test fix SimpleOpenWireTest

clebertsuconic-2
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 <[hidden email]>
Authored: Thu Jul 13 16:13:13 2017 -0400
Committer: Clebert Suconic <[hidden email]>
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();
 

Loading...