@@ -51,8 +51,8 @@ public void consumeMessageBefore(ConsumeMessageContext context) {
5151 }
5252 TraceContext traceContext = new TraceContext ();
5353 context .setMqTraceContext (traceContext );
54- traceContext .setTraceType (TraceType .SubBefore );//
55- traceContext .setGroupName (NamespaceUtil .withoutNamespace (context .getConsumerGroup ()));//
54+ traceContext .setTraceType (TraceType .SubBefore );
55+ traceContext .setGroupName (NamespaceUtil .withoutNamespace (context .getConsumerGroup ()));
5656 List <TraceBean > beans = new ArrayList <>();
5757 for (MessageExt msg : context .getMsgList ()) {
5858 if (msg == null ) {
@@ -66,14 +66,14 @@ public void consumeMessageBefore(ConsumeMessageContext context) {
6666 continue ;
6767 }
6868 TraceBean traceBean = new TraceBean ();
69- traceBean .setTopic (NamespaceUtil .withoutNamespace (msg .getTopic ()));//
70- traceBean .setMsgId (msg .getMsgId ());//
71- traceBean .setTags (msg .getTags ());//
72- traceBean .setKeys (msg .getKeys ());//
73- traceBean .setStoreTime (msg .getStoreTimestamp ());//
74- traceBean .setBodyLength (msg .getStoreSize ());//
75- traceBean .setRetryTimes (msg .getReconsumeTimes ());//
76- traceContext .setRegionId (regionId );//
69+ traceBean .setTopic (NamespaceUtil .withoutNamespace (msg .getTopic ()));
70+ traceBean .setMsgId (msg .getMsgId ());
71+ traceBean .setTags (msg .getTags ());
72+ traceBean .setKeys (msg .getKeys ());
73+ traceBean .setStoreTime (msg .getStoreTimestamp ());
74+ traceBean .setBodyLength (msg .getStoreSize ());
75+ traceBean .setRetryTimes (msg .getReconsumeTimes ());
76+ traceContext .setRegionId (regionId );
7777 beans .add (traceBean );
7878 }
7979 if (beans .size () > 0 ) {
@@ -95,16 +95,16 @@ public void consumeMessageAfter(ConsumeMessageContext context) {
9595 return ;
9696 }
9797 TraceContext subAfterContext = new TraceContext ();
98- subAfterContext .setTraceType (TraceType .SubAfter );//
99- subAfterContext .setRegionId (subBeforeContext .getRegionId ());//
100- subAfterContext .setGroupName (NamespaceUtil .withoutNamespace (subBeforeContext .getGroupName ()));//
101- subAfterContext .setRequestId (subBeforeContext .getRequestId ());//
98+ subAfterContext .setTraceType (TraceType .SubAfter );
99+ subAfterContext .setRegionId (subBeforeContext .getRegionId ());
100+ subAfterContext .setGroupName (NamespaceUtil .withoutNamespace (subBeforeContext .getGroupName ()));
101+ subAfterContext .setRequestId (subBeforeContext .getRequestId ());
102102 subAfterContext .setAccessChannel (context .getAccessChannel ());
103- subAfterContext .setSuccess (context .isSuccess ());//
103+ subAfterContext .setSuccess (context .isSuccess ());
104104
105105 // Calculate the cost time for processing messages
106106 int costTime = (int ) ((System .currentTimeMillis () - subBeforeContext .getTimeStamp ()) / context .getMsgList ().size ());
107- subAfterContext .setCostTime (costTime );//
107+ subAfterContext .setCostTime (costTime );
108108 subAfterContext .setTraceBeans (subBeforeContext .getTraceBeans ());
109109 Map <String , String > props = context .getProps ();
110110 if (props != null ) {
0 commit comments