[#Issue3205]Fix the issue of code style in client and broker modules.

apache · Aug 1, 2021 · 73db297 · 73db297
1 parent 5e58893
commit 73db297
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
@@ -22,7 +22,6 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.Objects;
 import java.util.Random;
 import org.apache.rocketmq.broker.BrokerController;
 import org.apache.rocketmq.broker.mqtrace.SendMessageContext;

diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureTable.java b/client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureTable.java
@@ -32,7 +32,7 @@
 public class RequestFutureTable {
     private static InternalLogger log = ClientLogger.getLog();
     private static ConcurrentHashMap<String, RequestResponseFuture> requestFutureTable = new ConcurrentHashMap<String, RequestResponseFuture>();
-    private static final AtomicInteger producerNum = new AtomicInteger(0);
+    private static final AtomicInteger PRODUCER_NUM = new AtomicInteger(0);
 
     public static ConcurrentHashMap<String, RequestResponseFuture> getRequestFutureTable() {
         return requestFutureTable;
@@ -64,6 +64,6 @@ public static void scanExpiredRequest() {
     }
 
     public static AtomicInteger getProducerNum() {
-        return producerNum;
+        return PRODUCER_NUM;
     }
 }