diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2021-07-17 07:34:48 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2021-07-17 07:34:57 +0000 |
commit | d71fd6264d58795c50b9350d7c39677b671e0896 (patch) | |
tree | 0aa9e0bd923a00b9ddda4e01af55a76ed314097c /iredis/data/commands/xclaim.md | |
parent | Releasing debian version 1.9.1-3. (diff) | |
download | iredis-d71fd6264d58795c50b9350d7c39677b671e0896.tar.xz iredis-d71fd6264d58795c50b9350d7c39677b671e0896.zip |
Merging upstream version 1.9.4.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'iredis/data/commands/xclaim.md')
-rw-r--r-- | iredis/data/commands/xclaim.md | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/iredis/data/commands/xclaim.md b/iredis/data/commands/xclaim.md index e6ee8c9..7b611d2 100644 --- a/iredis/data/commands/xclaim.md +++ b/iredis/data/commands/xclaim.md @@ -5,14 +5,15 @@ command argument. Normally this is what happens: 1. There is a stream with an associated consumer group. 2. Some consumer A reads a message via `XREADGROUP` from a stream, in the context of that consumer group. -3. As a side effect a pending message entry is created in the pending entries - list (PEL) of the consumer group: it means the message was delivered to a +3. As a side effect a pending message entry is created in the Pending Entries + List (PEL) of the consumer group: it means the message was delivered to a given consumer, but it was not yet acknowledged via `XACK`. 4. Then suddenly that consumer fails forever. 5. Other consumers may inspect the list of pending messages, that are stale for quite some time, using the `XPENDING` command. In order to continue processing such messages, they use `XCLAIM` to acquire the ownership of the - message and continue. + message and continue. As of Redis 6.2, consumers can use the `XAUTOCLAIM` + command to automatically scan and claim stale pending messages. This dynamic is clearly explained in the [Stream intro documentation](/topics/streams-intro). @@ -68,7 +69,7 @@ The command returns all the messages successfully claimed, in the same format as `XRANGE`. However if the `JUSTID` option was specified, only the message IDs are reported, without including the actual message. -Example: +@examples ``` > XCLAIM mystream mygroup Alice 3600000 1526569498055-0 |