SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polish

Browse Source
This commit is contained in:
Marcin Grzejszczak
2016-11-06 20:02:28 +01:00
parent 3b14e6a1f7
commit 2ab2eb1747
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/MessagingTextMap.java
View File

@@ -60,14 +60,10 @@ class MessagingTextMap implements SpanTextMap {
Message<?> initialMessage = this.delegate.build();
MessageHeaderAccessor accessor = MessageHeaderAccessor
.getMutableAccessor(initialMessage);
Map<String, String> headers = new HashMap<>();
headers.put(key, value);
accessor.copyHeaders(headers);
accessor.setHeader(key, value);
if (accessor instanceof NativeMessageHeaderAccessor) {
NativeMessageHeaderAccessor nativeAccessor = (NativeMessageHeaderAccessor) accessor;
for (String name : headers.keySet()) {
nativeAccessor.setNativeHeader(name, headers.get(name));
}
nativeAccessor.setNativeHeader(key, value);
}
this.delegate.copyHeaders(accessor.toMessageHeaders());
}