Fix bug in header names for streams

This commit is contained in:
Dave Syer
2015-08-19 13:53:07 +01:00
parent 7c33f2cb9c
commit db2cdacbfb

View File

@@ -59,9 +59,9 @@ public class TraceBootstrapEnvironmentPostProcessor implements EnvironmentPostPr
private void addHeaders(Map<String, Object> map, String type, String binder) {
if (ClassUtils.isPresent(type, null)) {
String stem = "spring.cloud.stream.binder." + binder + ".headers.";
String stem = "spring.cloud.stream.binder." + binder + ".headers";
for (int i = 0; i < headers.length; i++) {
map.put(stem + binder + ".headers[" + i + "]", headers[i]);
map.put(stem + "[" + i + "]", headers[i]);
}
}