From ccbc1b9cf3e0ad37494a1c7f41e7dbc783011178 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Tue, 17 Apr 2018 08:30:36 +0100 Subject: [PATCH] Fix broker registry issue --- options.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/options.go b/options.go index 09e6e546..2eb2c316 100644 --- a/options.go +++ b/options.go @@ -100,6 +100,8 @@ func Registry(r registry.Registry) Option { o.Server.Init(server.Registry(r)) // Update Selector o.Client.Options().Selector.Init(selector.Registry(r)) + // Update Broker + o.Broker.Init(broker.Registry(r)) } }