add missing outgoing key to ctx for subscribers (#279)

2025-06-11 03:22:10 +05:00
parent 19a8d7f7b1
commit fc50af50bb
1 changed files with 1 additions and 0 deletions
--- a/subscriber.go
+++ b/subscriber.go
@@ -133,6 +133,7 @@ func (g *Server) createSubHandler(sb *subscriber, opts server.Options) broker.Ha
 		}

 		ctx := metadata.NewIncomingContext(sb.opts.Context, hdr)
+		ctx = metadata.NewOutgoingContext(ctx, metadata.New(0))

 		results := make(chan error, len(sb.handlers))