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

This reverts commit 83de262c84.
This commit is contained in:
von gosling
2019-08-28 11:14:54 +08:00
committed by GitHub
parent 83de262c84
commit ce4478aa29
@@ -87,12 +87,12 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
} else {
this.traceTopicName = MixAll.RMQ_SYS_TRACE_TOPIC;
}
this.traceExecutor = new ThreadPoolExecutor(
10,
20,
1000 * 60,
TimeUnit.MILLISECONDS,
this.appenderQueue,
this.traceExecutor = new ThreadPoolExecutor(//
10, //
20, //
1000 * 60, //
TimeUnit.MILLISECONDS, //
this.appenderQueue, //
new ThreadFactoryImpl("MQTraceSendThread_"));
traceProducer = getAndCreateTraceProducer(rpcHook);
}
@@ -133,7 +133,6 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
this.hostConsumer = hostConsumer;
}
@Override
public void start(String nameSrvAddr, AccessChannel accessChannel) throws MQClientException {
if (isStarted.compareAndSet(false, true)) {
traceProducer.setNamesrvAddr(nameSrvAddr);