From b52d8514ce39bde71303e44b157252fecbe478d5 Mon Sep 17 00:00:00 2001 From: Luke Van Seters Date: Tue, 25 Jan 2022 11:14:05 -0500 Subject: [PATCH] Add instructions on clearing the queue to the README --- README.md | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/README.md b/README.md index 3f0854c..a7f5772 100644 --- a/README.md +++ b/README.md @@ -148,6 +148,12 @@ For messages permanently failed in the dead letter queue (XQ), query: HGETALL dramatiq:default.XQ.msgs ``` +To clear the queue, delete keys for the main queue and delay queue +``` +DEL dramatiq:default.msgs +DEL dramatiq:default.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)