Skip to content

Commit

Permalink
fixing error log
Browse files Browse the repository at this point in the history
  • Loading branch information
bagusandrian committed Nov 29, 2023
1 parent eb646b4 commit 4783eb3
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion nsqd/topic.go
Original file line number Diff line number Diff line change
Expand Up @@ -335,7 +335,7 @@ func (t *Topic) messagePump() {
err := channel.PutMessage(chanMsg)
if err != nil {
t.nsqd.logf(LOG_ERROR,
"TOPIC(%s) ERROR: failed to put msg(%s) to channel(%s) - %s will retry[%d]",
"TOPIC(%s) ERROR: failed to put msg(%s) to channel(%s) - %s",
t.name, msg.ID, channel.name, err)
if checkRetry >= msg.maxRetryChannel {
break
Expand Down

0 comments on commit 4783eb3

Please sign in to comment.