diff --git a/broker/http_broker.go b/broker/http_broker.go index b4c235c9..00119176 100644 --- a/broker/http_broker.go +++ b/broker/http_broker.go @@ -260,7 +260,6 @@ func (h *httpBroker) Publish(topic string, msg *Message, opts ...PublishOption) func (h *httpBroker) Subscribe(topic string, handler Handler, opts ...SubscribeOption) (Subscriber, error) { opt := newSubscribeOptions(opts...) - fmt.Println("subscribe to", topic) // parse address for host, port parts := strings.Split(h.Address(), ":") @@ -302,7 +301,6 @@ func (h *httpBroker) Subscribe(topic string, handler Handler, opts ...SubscribeO h.Lock() h.subscribers[topic] = append(h.subscribers[topic], subscriber) - fmt.Println(h.subscribers) h.Unlock() return subscriber, nil }