diff --git a/src/server.c b/src/server.c index 66d42ee6..b537ee04 100644 --- a/src/server.c +++ b/src/server.c @@ -310,14 +310,14 @@ struct redisCommand redisCommandTable[] = { {"xrange",xrangeCommand,-4,"r",0,NULL,1,1,1,0,0}, {"xrevrange",xrevrangeCommand,-4,"r",0,NULL,1,1,1,0,0}, {"xlen",xlenCommand,2,"rF",0,NULL,1,1,1,0,0}, - {"xread",xreadCommand,-3,"rs",0,xreadGetKeys,1,1,1,0,0}, - {"xreadgroup",xreadCommand,-3,"ws",0,xreadGetKeys,1,1,1,0,0}, + {"xread",xreadCommand,-4,"rs",0,xreadGetKeys,1,1,1,0,0}, + {"xreadgroup",xreadCommand,-7,"ws",0,xreadGetKeys,1,1,1,0,0}, {"xgroup",xgroupCommand,-2,"wm",0,NULL,2,2,1,0,0}, - {"xack",xackCommand,-3,"wF",0,NULL,1,1,1,0,0}, + {"xack",xackCommand,-4,"wF",0,NULL,1,1,1,0,0}, {"xpending",xpendingCommand,-3,"r",0,NULL,1,1,1,0,0}, - {"xclaim",xclaimCommand,-5,"wF",0,NULL,1,1,1,0,0}, + {"xclaim",xclaimCommand,-6,"wF",0,NULL,1,1,1,0,0}, {"xinfo",xinfoCommand,-2,"r",0,NULL,2,2,1,0,0}, - {"xdel",xdelCommand,-2,"wF",0,NULL,1,1,1,0,0}, + {"xdel",xdelCommand,-3,"wF",0,NULL,1,1,1,0,0}, {"xtrim",xtrimCommand,-2,"wF",0,NULL,1,1,1,0,0}, {"post",securityWarningCommand,-1,"lt",0,NULL,0,0,0,0,0}, {"host:",securityWarningCommand,-1,"lt",0,NULL,0,0,0,0,0}, diff --git a/src/t_stream.c b/src/t_stream.c index 72d03b46..d3156321 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -2040,12 +2040,12 @@ void xclaimCommand(client *c) { } else if (!strcasecmp(opt,"TIME") && moreargs) { j++; if (getLongLongFromObjectOrReply(c,c->argv[j],&deliverytime, - "Invalid IDLE option argument for XCLAIM") + "Invalid TIME option argument for XCLAIM") != C_OK) return; } else if (!strcasecmp(opt,"RETRYCOUNT") && moreargs) { j++; if (getLongLongFromObjectOrReply(c,c->argv[j],&retrycount, - "Invalid IDLE option argument for XCLAIM") + "Invalid RETRYCOUNT option argument for XCLAIM") != C_OK) return; } else { addReplyErrorFormat(c,"Unrecognized XCLAIM option '%s'",opt);