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

Use StreamListener for coercing messages from JSON Span (#386)

Browse Source 
* Use StreamListener for coercing messages from JSON `Span`

Rely on the `contentType` header of the transported message to
tell Spring Cloud Stream how to coerce the message to `Span`.
This commit is contained in:
Marius Bogoevici
2016-09-08 09:56:29 -04:00
committed by Marcin Grzejszczak
parent a9b4cbcfe6
commit bd8b64a5b9
3 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamEnvironmentPostProcessor.java
View File

@@ -74,9 +74,9 @@ public class StreamEnvironmentPostProcessor implements EnvironmentPostProcessor
// Technically this is only needed on the consumer, but it's fine to be explicit
// on producers as well. It puts all consumers in the same "group", meaning they
// compete with each other and only one gets each message.
map.put("spring.cloud.stream.bindings." + SleuthSink.INPUT + ".group",
map.put("spring.cloud.stream.bindings." + SleuthSource.OUTPUT + ".group",
environment.getProperty("spring.sleuth.stream.group", SleuthSink.INPUT));
map.put("spring.cloud.stream.bindings." + SleuthSink.INPUT + ".content-type",
map.put("spring.cloud.stream.bindings." + SleuthSource.OUTPUT + ".content-type",
environment.getProperty("spring.sleuth.stream.content-type", "application/json"));
addOrReplace(environment.getPropertySources(), map);
}