From da6c1be607440ed828c6b7d9eab2de4b40e8982e Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Wed, 20 Nov 2019 10:55:47 +0300 Subject: [PATCH] dont panic on missing headers in broker event (#963) Signed-off-by: Vasiliy Tolstov --- server/subscriber.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/server/subscriber.go b/server/subscriber.go index e3f29286..f0f85cf8 100644 --- a/server/subscriber.go +++ b/server/subscriber.go @@ -169,6 +169,11 @@ func (s *rpcServer) createSubHandler(sb *subscriber, opts Options) broker.Handle return func(p broker.Event) error { msg := p.Message() + if msg.Header == nil { + // create empty map in case of headers empty to avoid panic later + msg.Header = make(map[string]string) + } + // get codec ct := msg.Header["Content-Type"]