From eff39083ca6907f4be80f5b06cfd02ce4d2e2ce6 Mon Sep 17 00:00:00 2001 From: Pavel Arefiev Date: Thu, 24 Aug 2017 10:47:32 +0300 Subject: [PATCH] Pass options to the s.NewSubscriber --- go-micro.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go-micro.go b/go-micro.go index 818b3476..8d463cc3 100644 --- a/go-micro.go +++ b/go-micro.go @@ -81,5 +81,5 @@ func RegisterHandler(s server.Server, h interface{}, opts ...server.HandlerOptio // RegisterSubscriber is syntactic sugar for registering a subscriber func RegisterSubscriber(topic string, s server.Server, h interface{}, opts ...server.SubscriberOption) error { - return s.Subscribe(s.NewSubscriber(topic, h)) + return s.Subscribe(s.NewSubscriber(topic, h, opts...)) }