Clean jobs

1 files changed, 10 insertions, 4 deletions

diff --git a/src/queue/index.ts b/src/queue/index.ts
index 8912a7abfd..e6c3a7c29f 100644
--- a/src/queue/index.ts
+++ b/src/queue/index.ts
@@ -8,6 +8,7 @@ import { program } from '../argv';
 import processDeliver from './processors/deliver';
 import processInbox from './processors/process-inbox';
 import processDb from './processors/db';
+import { queueLogger } from './logger';
 
 function initializeQueue(name: string) {
 	return new Queue(name, config.redis != null ? {
@@ -124,8 +125,13 @@ export default function() {
 }
 
 export function destroy() {
-	/*
-	queue.destroy().then(n => {
-		queueLogger.succ(`All job removed (${n} jobs)`);
-	});*/
+	deliverQueue.once('cleaned', (jobs, status) => {
+		queueLogger.succ(`[deliver] Cleaned ${jobs.length} ${status} jobs`);
+	});
+	deliverQueue.clean(0, 'wait');
+
+	inboxQueue.once('cleaned', (jobs, status) => {
+		queueLogger.succ(`[inbox] Cleaned ${jobs.length} ${status} jobs`);
+	});
+	inboxQueue.clean(0, 'wait');
 }