XAUTOCLAIM

v0.1.0-beta.1

Scans and transfers eligible pending entries to a consumer.

Streams · Example verified

Syntax covered here

XAUTOCLAIM key group consumer min-idle-ms start-id

The case starts at 0-0 with zero minimum idle time and claims an entry previously delivered to another consumer.

Tested example & replies

Requests below run in order against an empty database. Each connection authenticates with the fixture password first. Quoted values are strings; null is a nil reply; arrays preserve RESP order.

# connection: default
> XADD events 1-0 event created
"1-0"
# connection: default
> XGROUP CREATE events workers 0
"OK"
# connection: default
> XREADGROUP GROUP workers alice STREAMS events >
[["events",[["1-0",["event","created"]]]]]
# connection: default
> XAUTOCLAIM events workers bob 0 0-0
["0-0",[["1-0",["event","created"]]],[]]