From 20ee57931f4ddbb29fcff93e4a7dc3b27a43eb9e Mon Sep 17 00:00:00 2001 From: syuilo Date: Wed, 6 Feb 2019 15:24:59 +0900 Subject: Resolve #4165 --- src/queue/index.ts | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'src/queue/index.ts') 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)`); + }); +} -- cgit v1.2.3-freya