diff --git a/src/t_stream.c b/src/t_stream.c index 335d1d82..3f31b5f9 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -1788,6 +1788,8 @@ void xclaimCommand(client *c) { /* Update the consumer and idle time. */ nack->consumer = consumer; nack->delivery_time = deliverytime; + /* Set the delivery attempts counter if given. */ + if (retrycount >= 0) nack->delivery_count = retrycount; /* Add the entry in the new cosnumer local PEL. */ raxInsert(consumer->pel,buf,sizeof(buf),nack,NULL); /* Send the reply for this entry. */