From db2cdacbfb2803e4828c8a545ff4e985a33cf49a Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@pivotal.io>
Date: Wed, 19 Aug 2015 13:53:07 +0100
Subject: [PATCH] Fix bug in header names for streams

---
 .../bootstrap/TraceBootstrapEnvironmentPostProcessor.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/bootstrap/TraceBootstrapEnvironmentPostProcessor.java b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/bootstrap/TraceBootstrapEnvironmentPostProcessor.java
index ab91a0e10..d97ccd09a 100644
--- a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/bootstrap/TraceBootstrapEnvironmentPostProcessor.java
+++ b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/bootstrap/TraceBootstrapEnvironmentPostProcessor.java
@@ -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]);
 			}
 		}