diff --git a/src/blocked.c b/src/blocked.c index e62d7548..2a349f0a 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -387,7 +387,11 @@ void handleClientsBlockedOnKeys(void) { /* If the group was not found, send an error * to the consumer. */ if (!group) { - /* XXX: Fixme, send the error. */ + addReplyError(receiver, + "-NOGROUP the consumer group this client " + "was blocked on no longer exists"); + unblockClient(receiver); + continue; } else { *gt = group->last_id; }