You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/08/01 10:41:38 UTC
[rocketmq] branch develop updated: [#Issue3205]Fix the issue of
code style in client and broker modules.
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 73db297 [#Issue3205]Fix the issue of code style in client and broker modules.
new ec985ee Merge pull request #3206 from zongtanghu/develop_fix_4.9.1_codestyle
73db297 is described below
commit 73db2970ff9fc5bfa018af3715b9cf641346cbe3
Author: zongtanghu <zo...@gmail.com>
AuthorDate: Sun Aug 1 18:22:54 2021 +0800
[#Issue3205]Fix the issue of code style in client and broker modules.
---
.../rocketmq/broker/processor/AbstractSendMessageProcessor.java | 1 -
.../java/org/apache/rocketmq/client/producer/RequestFutureTable.java | 4 ++--
2 files changed, 2 insertions(+), 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
index 2debf79..35f8660 100644
--- 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.net.SocketAddress;
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
index 52cda3e..9bdc3da 100644
--- 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 @@ import org.apache.rocketmq.logging.InternalLogger;
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 class RequestFutureTable {
}
public static AtomicInteger getProducerNum() {
- return producerNum;
+ return PRODUCER_NUM;
}
}