diff options
Diffstat (limited to 'src/queue/processors/http')
| -rw-r--r-- | src/queue/processors/http/deliver.ts | 2 | ||||
| -rw-r--r-- | src/queue/processors/http/index.ts | 19 |
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(); - } -}; |