1 files changed, 21 insertions, 0 deletions
diff --git a/src/queue/processors/index.ts b/src/queue/processors/index.ts
new file mode 100644
index 0000000000..3f08fe29fb
--- /dev/null
+++ b/src/queue/processors/index.ts
@@ -0,0 +1,21 @@
+import deliver from './http/deliver';
+import processInbox from './http/process-inbox';
+import { exportNotes } from './export-notes';
+import { queueLogger } from '../logger';
+
+const handlers: any = {
+	deliver,
+	processInbox,
+	exportNotes,
+};
+
+export default (job: any, done: any) => {
+	const handler = handlers[job.data.type];
+
+	if (handler) {
+		handler(job, done);
+	} else {
+		queueLogger.error(`Unknown job: ${job.data.type}`);
+		done();
+	}
+};