diff options
| author | dejun.xdj <dejun.xdj@alibaba-inc.com> | 2018-07-19 20:48:08 +0800 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-08-29 12:28:09 +0200 |
| commit | b59f04a099ec9fbfb9a1adc25e80dd6113198a00 (patch) | |
| tree | 6a0101b60e19bf33744a05cc487a7438b86b9f48 | |
| parent | a3f2437bddfebe7a3969069e539703dc6f2fbfad (diff) | |
| download | redis-b59f04a099ec9fbfb9a1adc25e80dd6113198a00.tar.gz | |
Streams: ID of xclaim command starts from the sixth argument.
| -rw-r--r-- | src/t_stream.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index d31563217..77fbf4645 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -2015,7 +2015,7 @@ void xclaimCommand(client *c) { * the client successfully claimed some message, so it should be * executed in a "all or nothing" fashion. */ int j; - for (j = 4; j < c->argc; j++) { + for (j = 5; j < c->argc; j++) { streamID id; if (streamParseStrictIDOrReply(NULL,c->argv[j],&id,0) != C_OK) break; } |