You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by pa...@apache.org on 2022/07/17 12:29:29 UTC
[rocketmq] branch develop updated: Fix typo
This is an automated email from the ASF dual-hosted git repository.
panzhi33 pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new c1b14b0dd Fix typo
new 0ba53e50b Merge pull request #4619 from Oliverwqcwrw/develop-fix-typo-27
c1b14b0dd is described below
commit c1b14b0dde6084f9799d912cf88228e292c89f5d
Author: Oliver <wq...@163.com>
AuthorDate: Sat Jul 16 22:23:23 2022 +0800
Fix typo
---
.../trace/hook/SendMessageTraceHookImpl.java | 32 +++++++++++-----------
1 file changed, 16 insertions(+), 16 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java b/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java
index 80c7babda..21e2bd922 100644
--- a/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java
@@ -46,12 +46,12 @@ public class SendMessageTraceHookImpl implements SendMessageHook {
if (context == null || context.getMessage().getTopic().startsWith(((AsyncTraceDispatcher) localDispatcher).getTraceTopicName())) {
return;
}
- //build the context content of TuxeTraceContext
- TraceContext tuxeContext = new TraceContext();
- tuxeContext.setTraceBeans(new ArrayList<TraceBean>(1));
- context.setMqTraceContext(tuxeContext);
- tuxeContext.setTraceType(TraceType.Pub);
- tuxeContext.setGroupName(NamespaceUtil.withoutNamespace(context.getProducerGroup()));
+ //build the context content of TraceContext
+ TraceContext traceContext = new TraceContext();
+ traceContext.setTraceBeans(new ArrayList<TraceBean>(1));
+ context.setMqTraceContext(traceContext);
+ traceContext.setTraceType(TraceType.Pub);
+ traceContext.setGroupName(NamespaceUtil.withoutNamespace(context.getProducerGroup()));
//build the data bean object of message trace
TraceBean traceBean = new TraceBean();
traceBean.setTopic(NamespaceUtil.withoutNamespace(context.getMessage().getTopic()));
@@ -60,7 +60,7 @@ public class SendMessageTraceHookImpl implements SendMessageHook {
traceBean.setStoreHost(context.getBrokerAddr());
traceBean.setBodyLength(context.getMessage().getBody().length);
traceBean.setMsgType(context.getMsgType());
- tuxeContext.getTraceBeans().add(traceBean);
+ traceContext.getTraceBeans().add(traceBean);
}
@Override
@@ -80,19 +80,19 @@ public class SendMessageTraceHookImpl implements SendMessageHook {
return;
}
- TraceContext tuxeContext = (TraceContext) context.getMqTraceContext();
- TraceBean traceBean = tuxeContext.getTraceBeans().get(0);
- int costTime = (int) ((System.currentTimeMillis() - tuxeContext.getTimeStamp()) / tuxeContext.getTraceBeans().size());
- tuxeContext.setCostTime(costTime);
+ TraceContext traceContext = (TraceContext) context.getMqTraceContext();
+ TraceBean traceBean = traceContext.getTraceBeans().get(0);
+ int costTime = (int) ((System.currentTimeMillis() - traceContext.getTimeStamp()) / traceContext.getTraceBeans().size());
+ traceContext.setCostTime(costTime);
if (context.getSendResult().getSendStatus().equals(SendStatus.SEND_OK)) {
- tuxeContext.setSuccess(true);
+ traceContext.setSuccess(true);
} else {
- tuxeContext.setSuccess(false);
+ traceContext.setSuccess(false);
}
- tuxeContext.setRegionId(context.getSendResult().getRegionId());
+ traceContext.setRegionId(context.getSendResult().getRegionId());
traceBean.setMsgId(context.getSendResult().getMsgId());
traceBean.setOffsetMsgId(context.getSendResult().getOffsetMsgId());
- traceBean.setStoreTime(tuxeContext.getTimeStamp() + costTime / 2);
- localDispatcher.append(tuxeContext);
+ traceBean.setStoreTime(traceContext.getTimeStamp() + costTime / 2);
+ localDispatcher.append(traceContext);
}
}