diff --git a/src/t_stream.c b/src/t_stream.c index 44251586..8540cfc6 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -1351,6 +1351,11 @@ void xreadCommand(client *c) { } if (strcmp(c->argv[i]->ptr,"$") == 0) { + if (xreadgroup) { + addReplyError(c,"The $ ID can be specified only when calling " + "XREAD without GROUP option."); + goto cleanup; + } if (o) { stream *s = o->ptr; ids[id_idx] = s->last_id;