Skip to content

Commit ce4478a

Browse files
authored
Revert "Remove end of line comment and add override annotation when rewrite method (alibaba#1420)" (alibaba#1423)
This reverts commit 83de262.
1 parent 83de262 commit ce4478a

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java

+6-7
Original file line numberDiff line numberDiff line change
@@ -87,12 +87,12 @@ public AsyncTraceDispatcher(String traceTopicName, RPCHook rpcHook) {
8787
} else {
8888
this.traceTopicName = MixAll.RMQ_SYS_TRACE_TOPIC;
8989
}
90-
this.traceExecutor = new ThreadPoolExecutor(
91-
10,
92-
20,
93-
1000 * 60,
94-
TimeUnit.MILLISECONDS,
95-
this.appenderQueue,
90+
this.traceExecutor = new ThreadPoolExecutor(//
91+
10, //
92+
20, //
93+
1000 * 60, //
94+
TimeUnit.MILLISECONDS, //
95+
this.appenderQueue, //
9696
new ThreadFactoryImpl("MQTraceSendThread_"));
9797
traceProducer = getAndCreateTraceProducer(rpcHook);
9898
}
@@ -133,7 +133,6 @@ public void setHostConsumer(DefaultMQPushConsumerImpl hostConsumer) {
133133
this.hostConsumer = hostConsumer;
134134
}
135135

136-
@Override
137136
public void start(String nameSrvAddr, AccessChannel accessChannel) throws MQClientException {
138137
if (isStarted.compareAndSet(false, true)) {
139138
traceProducer.setNamesrvAddr(nameSrvAddr);

0 commit comments

Comments
 (0)