summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2019-02-06 15:24:59 +0900
committersyuilo <syuilotan@yahoo.co.jp>2019-02-06 15:24:59 +0900
commit20ee57931f4ddbb29fcff93e4a7dc3b27a43eb9e (patch)
tree66f9ec6bcb963b8490ceabac36214efd40ba5123 /src/queue
parentBetter logs (diff)
downloadsharkey-20ee57931f4ddbb29fcff93e4a7dc3b27a43eb9e.tar.gz
sharkey-20ee57931f4ddbb29fcff93e4a7dc3b27a43eb9e.tar.bz2
sharkey-20ee57931f4ddbb29fcff93e4a7dc3b27a43eb9e.zip
Resolve #4165
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/index.ts6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts
index 8105999b60..da1c178a00 100644
--- a/src/queue/index.ts
+++ b/src/queue/index.ts
@@ -87,3 +87,9 @@ export default function() {
return queue;
}
+
+export function destroy() {
+ queue.destroy().then(n => {
+ queueLogger.succ(`All job removed (${n} jobs)`);
+ });
+}