Merge pull request 'client/noop: fix MessageMetadata option' (#274) from client-noop-metadata into v3

Reviewed-on: #274
This commit is contained in:
Василий Толстов 2023-10-26 03:07:12 +03:00
commit 6794ea9871
1 changed files with 7 additions and 0 deletions

View File

@ -490,6 +490,13 @@ func (n *noopClient) publish(ctx context.Context, ps []Message, opts ...PublishO
if !ok {
md = metadata.New(0)
}
iter := p.Metadata().Iterator()
var k, v string
for iter.Next(&k, &v) {
md.Set(k, v)
}
md[metadata.HeaderContentType] = p.ContentType()
topic := p.Topic()