diff --git a/src/t_stream.c b/src/t_stream.c index 726883d2..335d1d82 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -1770,6 +1770,7 @@ void xclaimCommand(client *c) { /* Create the NACK. */ nack = streamCreateNACK(NULL); + raxInsert(group->pel,buf,sizeof(buf),nack,NULL); } if (nack != raxNotFound) {