[fix][plugin-rocketmq] Fix agent tracing lost property separator (erd…

…a-project#93)
mxsl-gr · Jul 5, 2022 · 73f3193 · 73f3193
1 parent 529c918
commit 73f3193
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...-4.x-plugin/src/main/java/cloud/erda/agent/plugin/rocketmq/v4/MessageSendInterceptor.java b/...-4.x-plugin/src/main/java/cloud/erda/agent/plugin/rocketmq/v4/MessageSendInterceptor.java
@@ -84,7 +84,12 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         tracer.inject(span.getContext(), carrier);
 
         SendMessageRequestHeader requestHeader = (SendMessageRequestHeader) context.getArguments()[3];
-        StringBuilder properties = new StringBuilder(requestHeader.getProperties());
+        StringBuilder properties = new StringBuilder();
+        String originalProperties = requestHeader.getProperties();
+        if(originalProperties != null && !originalProperties.isEmpty()) {
+            properties.append(originalProperties);
+            properties.append(MessageDecoder.PROPERTY_SEPARATOR);
+        }
         for (Map.Entry<String, String> entry : map.entrySet()) {
             if (entry.getValue() == null) {
                 continue;