diff --git a/server/consumer.go b/server/consumer.go index f4b9dd512d4..86a02578f80 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -3076,7 +3076,7 @@ func (o *consumer) getNextMsg() (*jsPubMsg, uint64, error) { } // Process redelivered messages before looking at possibly "skip list" (deliver last per subject) if o.hasRedeliveries() { - seq, dc := o.sseq, uint64(1) + var seq, dc uint64 for seq = o.getNextToRedeliver(); seq > 0; seq = o.getNextToRedeliver() { dc = o.incDeliveryCount(seq) if o.maxdc > 0 && dc > o.maxdc { @@ -3137,8 +3137,6 @@ func (o *consumer) getNextMsg() (*jsPubMsg, uint64, error) { if value.pmsg == nil { pmsg := getJSPubMsgFromPool() sm, sseq, err := o.mset.store.LoadNextMsg(value.subject, value.hasWildcard, value.sequence, &pmsg.StoreMsg) - if err != nil { - } o.msseq[i].err = err if sm != nil {