summaryrefslogtreecommitdiff
path: root/src/queue/processors/http/index.ts
blob: 6f8d1dbc2bdd6cc6b11be6f226f87a36ab98e527 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
import deliver from './deliver';
import processInbox from './process-inbox';

const handlers = {
	deliver,
	processInbox,
};

export default (job, done) => {
	const handler = handlers[job.data.type];

	if (handler) {
		handler(job, done);
	} else {
		console.error(`Unknown job: ${job.data.type}`);
		done();
	}
};