You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2019/08/28 03:14:36 UTC
[rocketmq] branch revert-1420-master created (now 25e43ca)
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a change to branch revert-1420-master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
at 25e43ca Revert "Remove end of line comment and add override annotation when rewrite method (#1420)"
This branch includes the following new commits:
new 25e43ca Revert "Remove end of line comment and add override annotation when rewrite method (#1420)"
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[rocketmq] 01/01: Revert "Remove end of line comment and add
override annotation when rewrite method (#1420)"
Posted by vo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a commit to branch revert-1420-master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 25e43ca3491f3ef96cea42d0f3109e78b2e03cca
Author: von gosling <vo...@apache.org>
AuthorDate: Wed Aug 28 11:14:31 2019 +0800
Revert "Remove end of line comment and add override annotation when rewrite method (#1420)"
This reverts commit 83de262c84bd18cab5a7e58a19e1490e9d680122.
---
.../apache/rocketmq/client/trace/AsyncTraceDispatcher.java | 13 ++++++-------
1 file changed, 6 insertions(+), 7 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java b/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
index 34af0fb..ca3bcfa 100644
--- a/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
+++ b/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
@@ -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);