diff --git a/src/t_stream.c b/src/t_stream.c index e6538bd8..075386dd 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -1783,8 +1783,10 @@ void xpendingCommand(client *c) { /* If a consumer name was mentioned but it does not exist, we can * just return an empty array. */ - if (consumername && consumer == NULL) + if (consumername && consumer == NULL) { addReplyMultiBulkLen(c,0); + return; + } rax *pel = consumer ? consumer->pel : group->pel; unsigned char startkey[sizeof(streamID)];