提交 83de262c 编写于 作者: Z zhangzhikai 提交者: von gosling

Remove end of line comment and add override annotation when rewrite method (#1420)

上级 2c414fa5
...@@ -87,12 +87,12 @@ public class AsyncTraceDispatcher implements TraceDispatcher { ...@@ -87,12 +87,12 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
} else { } else {
this.traceTopicName = MixAll.RMQ_SYS_TRACE_TOPIC; this.traceTopicName = MixAll.RMQ_SYS_TRACE_TOPIC;
} }
this.traceExecutor = new ThreadPoolExecutor(// this.traceExecutor = new ThreadPoolExecutor(
10, // 10,
20, // 20,
1000 * 60, // 1000 * 60,
TimeUnit.MILLISECONDS, // TimeUnit.MILLISECONDS,
this.appenderQueue, // this.appenderQueue,
new ThreadFactoryImpl("MQTraceSendThread_")); new ThreadFactoryImpl("MQTraceSendThread_"));
traceProducer = getAndCreateTraceProducer(rpcHook); traceProducer = getAndCreateTraceProducer(rpcHook);
} }
...@@ -133,6 +133,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher { ...@@ -133,6 +133,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
this.hostConsumer = hostConsumer; this.hostConsumer = hostConsumer;
} }
@Override
public void start(String nameSrvAddr, AccessChannel accessChannel) throws MQClientException { public void start(String nameSrvAddr, AccessChannel accessChannel) throws MQClientException {
if (isStarted.compareAndSet(false, true)) { if (isStarted.compareAndSet(false, true)) {
traceProducer.setNamesrvAddr(nameSrvAddr); traceProducer.setNamesrvAddr(nameSrvAddr);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册