Fix broker registry issue

This commit is contained in:
Asim Aslam 2018-04-17 08:30:36 +01:00
parent 528b5f58de
commit ccbc1b9cf3

View File

@ -100,6 +100,8 @@ func Registry(r registry.Registry) Option {
o.Server.Init(server.Registry(r)) o.Server.Init(server.Registry(r))
// Update Selector // Update Selector
o.Client.Options().Selector.Init(selector.Registry(r)) o.Client.Options().Selector.Init(selector.Registry(r))
// Update Broker
o.Broker.Init(broker.Registry(r))
} }
} }