summaryrefslogtreecommitdiff
path: root/src/queue/processors/http
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue/processors/http')
-rw-r--r--src/queue/processors/http/deliver.ts2
-rw-r--r--src/queue/processors/http/index.ts19
2 files changed, 1 insertions, 20 deletions
diff --git a/src/queue/processors/http/deliver.ts b/src/queue/processors/http/deliver.ts
index d8d90a2773..d1dad55cd7 100644
--- a/src/queue/processors/http/deliver.ts
+++ b/src/queue/processors/http/deliver.ts
@@ -1,7 +1,7 @@
import * as bq from 'bee-queue';
import request from '../../../remote/activitypub/request';
-import { queueLogger } from '../..';
+import { queueLogger } from '../../logger';
export default async (job: bq.Job, done: any): Promise<void> => {
try {
diff --git a/src/queue/processors/http/index.ts b/src/queue/processors/http/index.ts
deleted file mode 100644
index 74ed723bd3..0000000000
--- a/src/queue/processors/http/index.ts
+++ /dev/null
@@ -1,19 +0,0 @@
-import deliver from './deliver';
-import processInbox from './process-inbox';
-import { queueLogger } from '../..';
-
-const handlers: any = {
- deliver,
- processInbox,
-};
-
-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();
- }
-};