未验证 提交 ec985ee6 编写于 作者: H Heng Du 提交者: GitHub

Merge pull request #3206 from zongtanghu/develop_fix_4.9.1_codestyle

[Issue3205]Fix the issue of check style in client and broker modules.
......@@ -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;
......
......@@ -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;
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册