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 2021/05/20 08:29:53 UTC
[rocketmq] branch develop updated: [ISSUE #2921]Fix consume
msgtrace loss (#2922)
This is an automated email from the ASF dual-hosted git repository.
vongosling 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 908782f [ISSUE #2921]Fix consume msgtrace loss (#2922)
908782f is described below
commit 908782f056859603fe238984afd9bb530110f583
Author: zhangjidi2016 <10...@qq.com>
AuthorDate: Thu May 20 16:29:39 2021 +0800
[ISSUE #2921]Fix consume msgtrace loss (#2922)
* [ISSUE #2898] Resolve rocketmq-example project failed during checkstyle execution
* [ISSUE #2921] Fix a bug in trace when consume message.
---
.../src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java b/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java
index b2b0645..2625d35 100644
--- a/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java
+++ b/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java
@@ -198,6 +198,7 @@ public class TraceDataEncoder {
}
}
+ break;
case EndTransaction: {
TraceBean bean = ctx.getTraceBeans().get(0);
sb.append(ctx.getTraceType()).append(TraceConstants.CONTENT_SPLITOR)//