161sh/iceshrimp-161sh
1
0
Fork 0
mirror of https://iceshrimp.dev/crimekillz/iceshrimp-161sh.git synced 2024-11-22 12:13:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Clean jobs

Browse Source
This commit is contained in:
syuilo 2019-03-07 23:36:08 +09:00
parent edb1db8761
commit d0af1798ee
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/queue/index.ts
View File

@ -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');
}