From 0016752fc1fb2e668aacfd4d50d31696647f6c5c Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Tue, 21 May 2019 07:49:30 +0000 Subject: [PATCH] accept publisher options --- publisher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/publisher.go b/publisher.go index ca81469c..c3bfbff3 100644 --- a/publisher.go +++ b/publisher.go @@ -12,5 +12,5 @@ type publisher struct { } func (p *publisher) Publish(ctx context.Context, msg interface{}, opts ...client.PublishOption) error { - return p.c.Publish(ctx, p.c.NewMessage(p.topic, msg)) + return p.c.Publish(ctx, p.c.NewMessage(p.topic, msg), opts...) }