Skip to content

Commit

Permalink
[IMPROVED] Don't error to server logs if message was deleted for cons…
Browse files Browse the repository at this point in the history
…umer (#4328)

Signed-off-by: Derek Collison <derek@nats.io>
  • Loading branch information
derekcollison committed Jul 20, 2023
2 parents 6c9fb6a + 9280a55 commit da60f2a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion server/consumer.go
Expand Up @@ -3506,7 +3506,7 @@ func (o *consumer) loopAndGatherMsgs(qch chan struct{}) {
if err == ErrStoreEOF {
o.checkNumPendingOnEOF()
}
if err == ErrStoreMsgNotFound || err == ErrStoreEOF || err == errMaxAckPending || err == errPartialCache {
if err == ErrStoreMsgNotFound || err == errDeletedMsg || err == ErrStoreEOF || err == errMaxAckPending || err == errPartialCache {
goto waitForMsgs
} else {
s.Errorf("Received an error looking up message for consumer: %v", err)
Expand Down

0 comments on commit da60f2a

Please sign in to comment.