From fc50af50bb799c7d6a46e033e9973848a2f1095b Mon Sep 17 00:00:00 2001 From: pugnack Date: Wed, 11 Jun 2025 03:22:10 +0500 Subject: [PATCH] add missing outgoing key to ctx for subscribers (#279) --- subscriber.go | 1 + 1 file changed, 1 insertion(+) diff --git a/subscriber.go b/subscriber.go index e3ef6b3..a73932a 100644 --- 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))