Comment typo in gRPC subscriber (#1304)
This commit is contained in:
parent
d807dac2a7
commit
a851b9db7a
@ -178,7 +178,7 @@ func (g *grpcServer) createSubHandler(sb *subscriber, opts server.Options) broke
|
|||||||
}()
|
}()
|
||||||
|
|
||||||
msg := p.Message()
|
msg := p.Message()
|
||||||
// if we don't ave headers, create empty map
|
// if we don't have headers, create empty map
|
||||||
if msg.Header == nil {
|
if msg.Header == nil {
|
||||||
msg.Header = make(map[string]string)
|
msg.Header = make(map[string]string)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user