Merge 9a3cd64a91fb85cfaaa93f3404ed97e287f92054 into ce8179f07e4fb8740b43570aa2c5826447c2af26
This commit is contained in:
commit
47f823e4cb
10
README.md
10
README.md
@ -147,23 +147,23 @@ To see progress and failed batches, connect to Redis with
|
||||
|
||||
For total messages, query:
|
||||
```
|
||||
HLEN dramatiq:default.msgs
|
||||
HLEN dramatiq:low.msgs
|
||||
```
|
||||
|
||||
For messages failed and waiting to retry in the delay queue (DQ), query:
|
||||
```
|
||||
HGETALL dramatiq:default.DQ.msgs
|
||||
HGETALL dramatiq:low.DQ.msgs
|
||||
```
|
||||
|
||||
For messages permanently failed in the dead letter queue (XQ), query:
|
||||
```
|
||||
HGETALL dramatiq:default.XQ.msgs
|
||||
HGETALL dramatiq:low.XQ.msgs
|
||||
```
|
||||
|
||||
To clear the queue, delete keys for the main queue and delay queue
|
||||
```
|
||||
DEL dramatiq:default.msgs
|
||||
DEL dramatiq:default.DQ.msgs
|
||||
DEL dramatiq:low.msgs
|
||||
DEL dramatiq:low.DQ.msgs
|
||||
```
|
||||
|
||||
For more information on queues, see the [spec shared by dramatiq](https://github.com/Bogdanp/dramatiq/blob/24cbc0dc551797783f41b08ea461e1b5d23a4058/dramatiq/brokers/redis/dispatch.lua#L24-L43)
|
||||
|
Loading…
x
Reference in New Issue
Block a user