提交 73db2970 编写于 作者: Z zongtanghu

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

上级 5e58893e
...@@ -22,7 +22,6 @@ import java.net.SocketAddress; ...@@ -22,7 +22,6 @@ import java.net.SocketAddress;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects;
import java.util.Random; import java.util.Random;
import org.apache.rocketmq.broker.BrokerController; import org.apache.rocketmq.broker.BrokerController;
import org.apache.rocketmq.broker.mqtrace.SendMessageContext; import org.apache.rocketmq.broker.mqtrace.SendMessageContext;
......
...@@ -32,7 +32,7 @@ import org.apache.rocketmq.logging.InternalLogger; ...@@ -32,7 +32,7 @@ import org.apache.rocketmq.logging.InternalLogger;
public class RequestFutureTable { public class RequestFutureTable {
private static InternalLogger log = ClientLogger.getLog(); private static InternalLogger log = ClientLogger.getLog();
private static ConcurrentHashMap<String, RequestResponseFuture> requestFutureTable = new ConcurrentHashMap<String, RequestResponseFuture>(); 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() { public static ConcurrentHashMap<String, RequestResponseFuture> getRequestFutureTable() {
return requestFutureTable; return requestFutureTable;
...@@ -64,6 +64,6 @@ public class RequestFutureTable { ...@@ -64,6 +64,6 @@ public class RequestFutureTable {
} }
public static AtomicInteger getProducerNum() { public static AtomicInteger getProducerNum() {
return producerNum; return PRODUCER_NUM;
} }
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册