From 0abd5265aa11df31492412d15192628b3f46ecc2 Mon Sep 17 00:00:00 2001
From: zhangke <zhangke_beijing@qq.com>
Date: Tue, 27 Dec 2016 18:21:18 +0800
Subject: [PATCH] [ROCKETMQ-19] Synchronize LinkedList.add() in multi-thread

---
 .../main/java/com/alibaba/rocketmq/client/impl/MQAdminImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/impl/MQAdminImpl.java b/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/impl/MQAdminImpl.java
index 9f7e964d5be..ea32609eac4 100644
--- a/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/impl/MQAdminImpl.java
+++ b/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/impl/MQAdminImpl.java
@@ -295,7 +295,7 @@ protected QueryResult queryMessage(String topic, String key, int maxNum, long be
 
             if (!brokerAddrs.isEmpty()) {
                 final CountDownLatch countDownLatch = new CountDownLatch(brokerAddrs.size());
-                final List<QueryResult> queryResultList = new LinkedList<QueryResult>();
+                final List<QueryResult> queryResultList = Collections.synchronizedList(new LinkedList<QueryResult>());
 
                 for (String addr : brokerAddrs) {
                     try {