Skip to content

Commit

Permalink
Fix lint errors
Browse files Browse the repository at this point in the history
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
  • Loading branch information
Jarema committed Jan 16, 2023
1 parent 6be2f65 commit 5f2ea90
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions server/consumer.go
Expand Up @@ -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 {
Expand Down Expand Up @@ -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 {
Expand Down

0 comments on commit 5f2ea90

Please sign in to comment.