未验证 提交 bbfdd929 编写于 作者: A androidkaifa1 提交者: GitHub

[ISSUE #2170] Update BrokerOuterAPI (#2203)

* READM.md: update BrokerOuterAPI

* fix tab error

* use thread-safe list

* use thread-safe list
上级 3774a227
...@@ -16,10 +16,10 @@ ...@@ -16,10 +16,10 @@
*/ */
package org.apache.rocketmq.broker.out; package org.apache.rocketmq.broker.out;
import com.google.common.collect.Lists;
import java.io.UnsupportedEncodingException; import java.io.UnsupportedEncodingException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Vector;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
...@@ -123,7 +123,7 @@ public class BrokerOuterAPI { ...@@ -123,7 +123,7 @@ public class BrokerOuterAPI {
final int timeoutMills, final int timeoutMills,
final boolean compressed) { final boolean compressed) {
final List<RegisterBrokerResult> registerBrokerResultList = Lists.newArrayList(); final List<RegisterBrokerResult> registerBrokerResultList = new Vector<>();
List<String> nameServerAddressList = this.remotingClient.getNameServerAddressList(); List<String> nameServerAddressList = this.remotingClient.getNameServerAddressList();
if (nameServerAddressList != null && nameServerAddressList.size() > 0) { if (nameServerAddressList != null && nameServerAddressList.size() > 0) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册