unistack-org/micro-client-grpc
3
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases 37 Wiki Activity

move set content-type in client publish
All checks were successful
lint / lint (pull_request) Successful in 1m37s
Details
test / test (pull_request) Successful in 3m5s
Details

Browse Source
This commit is contained in:
Денис Евстигнеев 2025-01-17 17:52:22 +03:00
parent 2d23f347eb
commit d5360e2804
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
grpc.go
View File

@ -803,7 +803,6 @@ func (g *grpcClient) publish(ctx context.Context, ps []client.Message, opts ...c
for _, p := range ps { for _, p := range ps {
md := metadata.Copy(omd) md := metadata.Copy(omd)
md[metadata.HeaderContentType] = p.ContentType()
topic := p.Topic() topic := p.Topic()
if len(exchange) > 0 { if len(exchange) > 0 {
topic = exchange topic = exchange
@ -815,6 +814,8 @@ func (g *grpcClient) publish(ctx context.Context, ps []client.Message, opts ...c
md.Set(k, v) md.Set(k, v)
} }
md[metadata.HeaderContentType] = p.ContentType()
// passed in raw data // passed in raw data
if d, ok := p.Payload().(*codec.Frame); ok { if d, ok := p.Payload().(*codec.Frame); ok {
body = d.Data body = d.Data