Compare commits
3 Commits
Author | SHA1 | Date | |
---|---|---|---|
9e0a58405f | |||
ee3f978683 | |||
46891c397f |
3
grpc.go
3
grpc.go
@@ -235,6 +235,9 @@ func (g *Server) handler(srv interface{}, stream grpc.ServerStream) (err error)
|
||||
md.Set(k, strings.Join(v, ", "))
|
||||
}
|
||||
md.Set("Path", fullMethod)
|
||||
md.Set("Micro-Server", "grpc")
|
||||
md.Set(metadata.HeaderEndpoint, methodName)
|
||||
md.Set(metadata.HeaderService, serviceName)
|
||||
|
||||
var td string
|
||||
// timeout for server deadline
|
||||
|
@@ -132,9 +132,6 @@ func (g *Server) createSubHandler(sb *subscriber, opts server.Options) broker.Ha
|
||||
|
||||
hdr := make(map[string]string, len(msg.Header))
|
||||
for k, v := range msg.Header {
|
||||
if k == "Content-Type" {
|
||||
continue
|
||||
}
|
||||
hdr[k] = v
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user