server/grpc: avoid panic in case of nil Header (#1303)

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-03-05 17:45:31 +03:00 · 2020-03-05 17:45:31 +03:00 · d807dac2a7
commit d807dac2a7
parent ce2ba71002
1 changed files with 5 additions and 0 deletions
--- a/server/grpc/subscriber.go
+++ b/server/grpc/subscriber.go
@ -178,6 +178,11 @@ func (g *grpcServer) createSubHandler(sb *subscriber, opts server.Options) broke
 		}()

 		msg := p.Message()
+		// if we don't ave headers, create empty map
+		if msg.Header == nil {
+			msg.Header = make(map[string]string)
+		}
+
 		ct := msg.Header["Content-Type"]
 		if len(ct) == 0 {
 			msg.Header["Content-Type"] = defaultContentType