Merge pull request 'client/noop: fix MessageMetadata option' (#274) from client-noop-metadata into v3
Reviewed-on: #274
This commit is contained in:
		| @@ -490,6 +490,13 @@ func (n *noopClient) publish(ctx context.Context, ps []Message, opts ...PublishO | |||||||
| 		if !ok { | 		if !ok { | ||||||
| 			md = metadata.New(0) | 			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() | 		md[metadata.HeaderContentType] = p.ContentType() | ||||||
|  |  | ||||||
| 		topic := p.Topic() | 		topic := p.Topic() | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user