CG: Replication WIP 1: XREADGROUP and XCLAIM propagated as XCLAIM.

1 files changed, 6 insertions, 1 deletions

diff --git a/src/blocked.c b/src/blocked.c
index 2de798378..23142d1d1 100644
--- a/src/blocked.c
+++ b/src/blocked.c
@@ -348,9 +348,14 @@ void handleClientsBlockedOnKeys(void) {
                             addReplyMultiBulkLen(receiver,1);
                             addReplyMultiBulkLen(receiver,2);
                             addReplyBulk(receiver,rl->key);
+
+                            streamPropInfo pi = {
+                                rl->key,
+                                receiver->bpop.xread_group
+                            };
                             streamReplyWithRange(receiver,s,&start,NULL,
                                                  receiver->bpop.xread_count,
-                                                 0, group, consumer, 0);
+                                                 0, group, consumer, 0, &pi);
                         }
                     }
                 }