diff --git a/nsqd/nsqd.go b/nsqd/nsqd.go index 5065e0c37..a5844ec8e 100644 --- a/nsqd/nsqd.go +++ b/nsqd/nsqd.go @@ -216,7 +216,6 @@ func (n *NSQD) GetStartTime() time.Time { // AddClient adds a client to the producers map func (n *NSQD) AddClient(clientID int64, client Client) { n.Lock() - n.clients[clientID] = client n.Unlock() } @@ -224,7 +223,6 @@ func (n *NSQD) AddClient(clientID int64, client Client) { // RemoveClient removes a client from the producers map func (n *NSQD) RemoveClient(clientID int64) { n.Lock() - _, ok := n.clients[clientID] if !ok { n.Unlock()