From 750b6d4733827dbca219bf487b66d59fef3479e2 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Tue, 28 Apr 2020 19:29:00 +0300 Subject: [PATCH] broker: add publish context (#1590) Signed-off-by: Vasiliy Tolstov --- grpc.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/grpc.go b/grpc.go index d41d977..9445eab 100644 --- 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 {