broker: add publish context (#1590)

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-04-28 19:29:00 +03:00 · 2020-04-28 19:29:00 +03:00 · 750b6d4733
commit 750b6d4733
parent e9db13acab
1 changed files with 1 additions and 1 deletions
--- a/grpc.go
+++ b/grpc.go
@ -653,7 +653,7 @@ func (g *grpcClient) Publish(ctx context.Context, p client.Message, opts ...clie
 	return g.opts.Broker.Publish(topic, &broker.Message{
 		Header: md,
 		Body:   body,
-	})
+	}, broker.PublishContext(options.Context))
 }

 func (g *grpcClient) String() string {