From e6d434c1679791a2327c48036c13210b568a6fe6 Mon Sep 17 00:00:00 2001
From: antirez <antirez@gmail.com>
Date: Fri, 2 Mar 2018 16:23:34 +0100
Subject: [PATCH] CG: implement RETRYCOUNT in XCLAIM.

---
 src/t_stream.c | 2 ++
 1 file changed, 2 insertions(+)

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. */