File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
broker/src/main/java/org/apache/rocketmq/broker/out Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change 1919import java .io .UnsupportedEncodingException ;
2020import java .util .ArrayList ;
2121import java .util .List ;
22- import java .util .Vector ;
2322import java .util .concurrent .ArrayBlockingQueue ;
2423import java .util .concurrent .CopyOnWriteArrayList ;
2524import java .util .concurrent .CountDownLatch ;
@@ -123,7 +122,7 @@ public List<RegisterBrokerResult> registerBrokerAll(
123122 final int timeoutMills ,
124123 final boolean compressed ) {
125124
126- final List <RegisterBrokerResult > registerBrokerResultList = new Vector <>();
125+ final List <RegisterBrokerResult > registerBrokerResultList = new CopyOnWriteArrayList <>();
127126 List <String > nameServerAddressList = this .remotingClient .getNameServerAddressList ();
128127 if (nameServerAddressList != null && nameServerAddressList .size () > 0 ) {
129128
You can’t perform that action at this time.
0 commit comments