Skip to content

Commit 4634069

Browse files
authored
[fix][plugin-rocketmq] Fix agent tracing lost property separator (#93) (#94)
1 parent 529c918 commit 4634069

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

agent-plugins/agent-rocketmq-4.x-plugin/src/main/java/cloud/erda/agent/plugin/rocketmq/v4/MessageSendInterceptor.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,12 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
8484
tracer.inject(span.getContext(), carrier);
8585

8686
SendMessageRequestHeader requestHeader = (SendMessageRequestHeader) context.getArguments()[3];
87-
StringBuilder properties = new StringBuilder(requestHeader.getProperties());
87+
StringBuilder properties = new StringBuilder();
88+
String originalProperties = requestHeader.getProperties();
89+
if(originalProperties != null && !originalProperties.isEmpty()) {
90+
properties.append(originalProperties);
91+
properties.append(MessageDecoder.PROPERTY_SEPARATOR);
92+
}
8893
for (Map.Entry<String, String> entry : map.entrySet()) {
8994
if (entry.getValue() == null) {
9095
continue;

0 commit comments

Comments
 (0)