You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/07/13 20:23:10 UTC
activemq-artemis git commit: ARTEMIS-1287 Simple test fix
SimpleOpenWireTest
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 <cl...@apache.org>
Authored: Thu Jul 13 16:13:13 2017 -0400
Committer: Clebert Suconic <cl...@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();