|
12 | 12 | import org.slf4j.LoggerFactory; |
13 | 13 | import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants; |
14 | 14 |
|
| 15 | +import javax.servlet.http.HttpServletRequest; |
15 | 16 | import java.io.BufferedReader; |
16 | 17 | import java.io.IOException; |
17 | 18 | import java.io.InputStreamReader; |
| 19 | +import java.util.Enumeration; |
18 | 20 | import java.util.stream.Collectors; |
19 | 21 |
|
20 | 22 | /** |
@@ -53,9 +55,15 @@ public Object run() { |
53 | 55 | .uri((String)context.get(FilterConstants.REQUEST_URI_KEY)) |
54 | 56 | .ip(context.getZuulRequestHeaders().get(FilterConstants.X_FORWARDED_FOR_HEADER.toLowerCase())) |
55 | 57 | .addMultiParams(context.getRequestQueryParams()) |
56 | | - .addHeaders(context.getZuulRequestHeaders()) |
57 | | - .addHeaders(context.getOriginResponseHeaders().stream().collect(Collectors.toMap(Pair::first, Pair::second))); |
58 | | - context.getOriginResponseHeaders().forEach(pair-> builder.addHeader(pair.first(), pair.second())); |
| 58 | + .addHeaders(context.getZuulRequestHeaders()); |
| 59 | + |
| 60 | + // add http server request header |
| 61 | + HttpServletRequest servletRequest = context.getRequest(); |
| 62 | + Enumeration<String> headerNames = servletRequest.getHeaderNames(); |
| 63 | + while(headerNames.hasMoreElements()){ |
| 64 | + String headerName = headerNames.nextElement(); |
| 65 | + builder.addHeader(headerName, servletRequest.getHeader(headerName)); |
| 66 | + } |
59 | 67 |
|
60 | 68 | if(bambooProperties.getBambooRequest().isLoadBody()) { |
61 | 69 | try { |
|
0 commit comments