diff --git a/client/noop.go b/client/noop.go index 52a4da68..dd4085cb 100644 --- a/client/noop.go +++ b/client/noop.go @@ -486,11 +486,12 @@ func (n *noopClient) publish(ctx context.Context, ps []Message, opts ...PublishO msgs := make([]*broker.Message, 0, len(ps)) for _, p := range ps { - md, ok := metadata.FromOutgoingContext(ctx) + omd, ok := metadata.FromOutgoingContext(ctx) if !ok { - md = metadata.New(0) + omd = metadata.New(0) } + md := metadata.Copy(omd) iter := p.Metadata().Iterator() var k, v string for iter.Next(&k, &v) {