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