diff --git a/src/t_stream.c b/src/t_stream.c index 398f8ba0b..38ed804a7 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -2208,9 +2208,9 @@ void xreadCommand(client *c) { streams_arg = i+1; streams_count = (c->argc-streams_arg); if ((streams_count % 2) != 0) { - addReplyError(c,"Unbalanced XREAD list of streams: " - "for each stream key an ID or '$' must be " - "specified."); + addReplyErrorFormat(c,"Unbalanced '%s' list of streams: " + "for each stream key an ID or '>' must be " + "specified.", c->cmd->fullname); return; } streams_count /= 2; /* We have two arguments for each stream. */