提交 e2c697bf 编写于 作者: D duhenglucky

Modify checkstyle remove chinese characters

上级 0235a706
...@@ -16,6 +16,19 @@ ...@@ -16,6 +16,19 @@
*/ */
package org.apache.rocketmq.client.trace; package org.apache.rocketmq.client.trace;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
import org.apache.rocketmq.client.common.ThreadLocalIndex; import org.apache.rocketmq.client.common.ThreadLocalIndex;
import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.impl.consumer.MQPushConsumerInner; import org.apache.rocketmq.client.impl.consumer.MQPushConsumerInner;
...@@ -34,21 +47,6 @@ import org.apache.rocketmq.common.message.MessageQueue; ...@@ -34,21 +47,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.logging.InternalLogger; import org.apache.rocketmq.logging.InternalLogger;
import org.apache.rocketmq.remoting.RPCHook; import org.apache.rocketmq.remoting.RPCHook;
import java.io.IOException;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
import java.util.UUID;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.util.HashMap;
import java.util.Set;
import java.util.HashSet;
import static org.apache.rocketmq.client.trace.TraceConstants.TRACE_INSTANCE_NAME; import static org.apache.rocketmq.client.trace.TraceConstants.TRACE_INSTANCE_NAME;
public class AsyncTraceDispatcher implements TraceDispatcher { public class AsyncTraceDispatcher implements TraceDispatcher {
...@@ -73,7 +71,6 @@ public class AsyncTraceDispatcher implements TraceDispatcher { ...@@ -73,7 +71,6 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
private String traceTopicName; private String traceTopicName;
private AtomicBoolean isStarted = new AtomicBoolean(false); private AtomicBoolean isStarted = new AtomicBoolean(false);
public AsyncTraceDispatcher(String traceTopicName, RPCHook rpcHook) throws MQClientException { public AsyncTraceDispatcher(String traceTopicName, RPCHook rpcHook) throws MQClientException {
// queueSize is greater than or equal to the n power of 2 of value // queueSize is greater than or equal to the n power of 2 of value
this.queueSize = 2048; this.queueSize = 2048;
......
...@@ -48,7 +48,7 @@ public class LocalEnodeServiceImpl implements EnodeService { ...@@ -48,7 +48,7 @@ public class LocalEnodeServiceImpl implements EnodeService {
RemotingCommand request) { RemotingCommand request) {
CompletableFuture<RemotingCommand> completableFuture = new CompletableFuture<>(); CompletableFuture<RemotingCommand> completableFuture = new CompletableFuture<>();
try { try {
log.debug("Send message request{}", request); log.debug("Send message request: {}", request);
RemotingCommand remotingCommand = this.brokerController.getSendProcessor().processRequest(remotingChannel, request); RemotingCommand remotingCommand = this.brokerController.getSendProcessor().processRequest(remotingChannel, request);
CodecHelper.encodeHeader(remotingCommand); CodecHelper.encodeHeader(remotingCommand);
completableFuture.complete(remotingCommand); completableFuture.complete(remotingCommand);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册