remove the print statements
This commit is contained in:
parent
d0b2b612f3
commit
10d2ad0de9
@ -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) {
|
func (h *httpBroker) Subscribe(topic string, handler Handler, opts ...SubscribeOption) (Subscriber, error) {
|
||||||
opt := newSubscribeOptions(opts...)
|
opt := newSubscribeOptions(opts...)
|
||||||
fmt.Println("subscribe to", topic)
|
|
||||||
|
|
||||||
// parse address for host, port
|
// parse address for host, port
|
||||||
parts := strings.Split(h.Address(), ":")
|
parts := strings.Split(h.Address(), ":")
|
||||||
@ -302,7 +301,6 @@ func (h *httpBroker) Subscribe(topic string, handler Handler, opts ...SubscribeO
|
|||||||
|
|
||||||
h.Lock()
|
h.Lock()
|
||||||
h.subscribers[topic] = append(h.subscribers[topic], subscriber)
|
h.subscribers[topic] = append(h.subscribers[topic], subscriber)
|
||||||
fmt.Println(h.subscribers)
|
|
||||||
h.Unlock()
|
h.Unlock()
|
||||||
return subscriber, nil
|
return subscriber, nil
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user