Skip to content

Commit

Permalink
Update nsqd/channel.go
Browse files Browse the repository at this point in the history
Co-authored-by: Jehiah Czebotar <[email protected]>
  • Loading branch information
zoemccormick and jehiah authored May 21, 2024
1 parent b8abbec commit 9f4cba4
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion nsqd/channel.go
Original file line number Diff line number Diff line change
Expand Up @@ -335,7 +335,7 @@ func (c *Channel) put(m *Message) error {
// we do this to ensure that we preferentially deliver messages based on toplogy
//
// 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
// we continue to add lower priority channels in the select loop, this means at each
// attempt a higher priority channel can still win
select {
case c.zoneLocalMsgChan <- m:
Expand Down

0 comments on commit 9f4cba4

Please sign in to comment.