[rocketmq] branch master updated: [ISSUE #2283] Fix the spelling mistake in ProducerManager & some code optimization

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/master by this push:
     new 798d980  [ISSUE #2283] Fix the spelling mistake in ProducerManager & 
some code optimization
798d980 is described below

commit 798d9803b9e831b19957cbdb74571e4c6c341ce3
Author: 李强 <liqiang1...@163.com>
AuthorDate: Thu Sep 3 22:59:41 2020 +0800

    [ISSUE #2283] Fix the spelling mistake in ProducerManager & some code 
optimization
---
 .../org/apache/rocketmq/broker/client/ProducerManager.java   | 12 +++++-------
 .../AbstractTransactionalMessageCheckListener.java           |  2 +-
 .../apache/rocketmq/broker/client/ProducerManagerTest.java   |  8 ++++----
 3 files changed, 10 insertions(+), 12 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
index 860b349..4bd00ef 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
@@ -33,7 +33,7 @@ import org.apache.rocketmq.remoting.common.RemotingUtil;
 public class ProducerManager {
     private static final InternalLogger log = 
InternalLoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final long CHANNEL_EXPIRED_TIMEOUT = 1000 * 120;
-    private static final int GET_AVALIABLE_CHANNEL_RETRY_COUNT = 3;
+    private static final int GET_AVAILABLE_CHANNEL_RETRY_COUNT = 3;
     private final ConcurrentHashMap<String /* group name */, 
ConcurrentHashMap<Channel, ClientChannelInfo>> groupChannelTable =
         new ConcurrentHashMap<>();
     private final ConcurrentHashMap<String, Channel> clientChannelTable = new 
ConcurrentHashMap<>();
@@ -131,16 +131,14 @@ public class ProducerManager {
         }
     }
 
-    public Channel getAvaliableChannel(String groupId) {
+    public Channel getAvailableChannel(String groupId) {
         if (groupId == null) {
             return null;
         }
-        List<Channel> channelList = new ArrayList<Channel>();
+        List<Channel> channelList;
         ConcurrentHashMap<Channel, ClientChannelInfo> 
channelClientChannelInfoHashMap = groupChannelTable.get(groupId);
         if (channelClientChannelInfoHashMap != null) {
-            for (Channel channel : channelClientChannelInfoHashMap.keySet()) {
-                channelList.add(channel);
-            }
+            channelList = new 
ArrayList<>(channelClientChannelInfoHashMap.keySet());
         } else {
             log.warn("Check transaction failed, channel table is empty. 
groupId={}", groupId);
             return null;
@@ -158,7 +156,7 @@ public class ProducerManager {
         Channel channel = channelList.get(index);
         int count = 0;
         boolean isOk = channel.isActive() && channel.isWritable();
-        while (count++ < GET_AVALIABLE_CHANNEL_RETRY_COUNT) {
+        while (count++ < GET_AVAILABLE_CHANNEL_RETRY_COUNT) {
             if (isOk) {
                 return channel;
             }
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
index 35d8112..4cf5647 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
@@ -69,7 +69,7 @@ public abstract class 
AbstractTransactionalMessageCheckListener {
         
msgExt.setQueueId(Integer.parseInt(msgExt.getUserProperty(MessageConst.PROPERTY_REAL_QUEUE_ID)));
         msgExt.setStoreSize(0);
         String groupId = 
msgExt.getProperty(MessageConst.PROPERTY_PRODUCER_GROUP);
-        Channel channel = 
brokerController.getProducerManager().getAvaliableChannel(groupId);
+        Channel channel = 
brokerController.getProducerManager().getAvailableChannel(groupId);
         if (channel != null) {
             
brokerController.getBroker2Client().checkProducerTransactionState(groupId, 
channel, checkTransactionStateRequestHeader, msgExt);
         } else {
diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/client/ProducerManagerTest.java
 
b/broker/src/test/java/org/apache/rocketmq/broker/client/ProducerManagerTest.java
index 4791ab1..6c794ac 100644
--- 
a/broker/src/test/java/org/apache/rocketmq/broker/client/ProducerManagerTest.java
+++ 
b/broker/src/test/java/org/apache/rocketmq/broker/client/ProducerManagerTest.java
@@ -110,20 +110,20 @@ public class ProducerManagerTest {
     }
 
     @Test
-    public void testGetAvaliableChannel() {
+    public void testGetAvailableChannel() {
         producerManager.registerProducer(group, clientInfo);
 
         when(channel.isActive()).thenReturn(true);
         when(channel.isWritable()).thenReturn(true);
-        Channel c = producerManager.getAvaliableChannel(group);
+        Channel c = producerManager.getAvailableChannel(group);
         assertThat(c).isSameAs(channel);
 
         when(channel.isWritable()).thenReturn(false);
-        c = producerManager.getAvaliableChannel(group);
+        c = producerManager.getAvailableChannel(group);
         assertThat(c).isSameAs(channel);
 
         when(channel.isActive()).thenReturn(false);
-        c = producerManager.getAvaliableChannel(group);
+        c = producerManager.getAvailableChannel(group);
         assertThat(c).isNull();
     }