Skip to content

Commit

Permalink
remove unnecessary error log in decrementMsgIdByOne
Browse files Browse the repository at this point in the history
  • Loading branch information
ganeshvanahalli committed Sep 27, 2024
1 parent 9a96fbf commit 43a54e7
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions pubsub/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -100,10 +100,8 @@ func decrementMsgIdByOne(msgId string) string {
return strconv.FormatUint(id[0], 10) + "-" + strconv.FormatUint(id[1]-1, 10)
} else if id[0] > 0 {
return strconv.FormatUint(id[0]-1, 10) + "-" + strconv.FormatUint(math.MaxUint64, 10)
} else {
log.Error("Error decrementing start of XAutoClaim by one, defaulting to 0")
return "0"
}
return "0"
}

// Consumer first checks it there exists pending message that is claimed by
Expand Down

0 comments on commit 43a54e7

Please sign in to comment.