fix for latest micro

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2020-11-03 02:15:31 +03:00
parent edaf9eaaa6
commit 46ed1f8fa4
5 changed files with 24 additions and 17 deletions

View File

@@ -36,10 +36,7 @@ type subscriber struct {
}
func newSubscriber(topic string, sub interface{}, opts ...server.SubscriberOption) server.Subscriber {
options := server.NewSubscriberOptions()
for _, o := range opts {
o(&options)
}
options := server.NewSubscriberOptions(opts...)
var endpoints []*registry.Endpoint
var handlers []*handler