From bbfdd929f51c3459334d86684b2fa7912aa2b49d Mon Sep 17 00:00:00 2001 From: androidkaifa1 <2060344029@qq.com> Date: Tue, 11 Aug 2020 10:29:09 +0800 Subject: [PATCH] [ISSUE #2170] Update BrokerOuterAPI (#2203) * READM.md: update BrokerOuterAPI * fix tab error * use thread-safe list * use thread-safe list --- .../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 6caa2358..2495d9d6 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 registerBrokerResultList = Lists.newArrayList(); + final List registerBrokerResultList = new Vector<>(); List nameServerAddressList = this.remotingClient.getNameServerAddressList(); if (nameServerAddressList != null && nameServerAddressList.size() > 0) { -- GitLab