src/queue/processors/object-storage/index.ts


1
2
3
4
5
6
7
8
9
10
11
12

import * as Bull from 'bull';
import deleteFile from './delete-file';

const jobs = {
	deleteFile,
} as any;

export default function(q: Bull.Queue) {
	for (const [k, v] of Object.entries(jobs)) {
		q.process(k, v as any);
	}
}