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...)) }