diff --git a/broker/http_broker.go b/broker/http_broker.go index d50d8b12..c78c028d 100644 --- a/broker/http_broker.go +++ b/broker/http_broker.go @@ -257,13 +257,10 @@ func (h *httpBroker) Disconnect() error { } func (h *httpBroker) Init(opts ...Option) error { - var options Options for _, o := range opts { - o(&options) + o(&h.opts) } - h.opts = options - if len(h.id) == 0 { h.id = "broker-" + uuid.NewUUID().String() }