use the request header

2018-11-22 10:39:36 +00:00 · 2018-11-22 10:39:36 +00:00 · f1984650f4
commit f1984650f4
parent 5fd7da9de7
1 changed files with 1 additions and 1 deletions
--- a/transport/http_transport.go
+++ b/transport/http_transport.go
@ -238,7 +238,7 @@ func (h *httpTransportSocket) Recv(m *Message) error {
 		m.Body = b

 		// set headers
-		for k, v := range h.r.Header {
+		for k, v := range r.Header {
 			if len(v) > 0 {
 				m.Header[k] = v[0]
 			} else {