You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2020/08/11 02:29:22 UTC
[rocketmq] branch develop updated: [ISSUE #2170] Update
BrokerOuterAPI (#2203)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new bbfdd92 [ISSUE #2170] Update BrokerOuterAPI (#2203)
bbfdd92 is described below
commit bbfdd929f51c3459334d86684b2fa7912aa2b49d
Author: androidkaifa1 <20...@qq.com>
AuthorDate: Tue Aug 11 10:29:09 2020 +0800
[ISSUE #2170] Update BrokerOuterAPI (#2203)
* READM.md: update BrokerOuterAPI
* fix tab error
* use thread-safe list
* use thread-safe list
---
.../src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
index 6caa235..2495d9d 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
@@ -16,10 +16,10 @@
*/
package org.apache.rocketmq.broker.out;
-import com.google.common.collect.Lists;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;
+import java.util.Vector;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CountDownLatch;
@@ -123,7 +123,7 @@ public class BrokerOuterAPI {
final int timeoutMills,
final boolean compressed) {
- final List<RegisterBrokerResult> registerBrokerResultList = Lists.newArrayList();
+ final List<RegisterBrokerResult> registerBrokerResultList = new Vector<>();
List<String> nameServerAddressList = this.remotingClient.getNameServerAddressList();
if (nameServerAddressList != null && nameServerAddressList.size() > 0) {