diff --git a/nsqd/channel.go b/nsqd/channel.go index 3f2e0a56e..1d281ef3c 100644 --- a/nsqd/channel.go +++ b/nsqd/channel.go @@ -325,22 +325,6 @@ func (c *Channel) put(m *Message) error { // Because messagePump is intermittently unavailable while writing a msg to a client // we continue to have higher priority channels in the select loop, this means at each // attempt a higher priority channel can still win - select { - case c.zoneLocalMsgChan <- m: - atomic.AddUint64(&c.zoneLocalMsgCount, 1) - return nil - default: - } - select { - case c.zoneLocalMsgChan <- m: - atomic.AddUint64(&c.zoneLocalMsgCount, 1) - return nil - case c.regionLocalMsgChan <- m: - atomic.AddUint64(&c.regionLocalMsgCount, 1) - return nil - default: - } - select { case c.zoneLocalMsgChan <- m: atomic.AddUint64(&c.zoneLocalMsgCount, 1)