diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2018-07-26 08:11:47 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2018-07-26 08:11:47 +0900 |
| commit | 77b493c9b065a7af7533e718f8623f810e65341a (patch) | |
| tree | 0830dd5f4accae60d7920417af2026830eb884e8 /src/queue/processors/http/process-inbox.ts | |
| parent | :v: (diff) | |
| download | sharkey-77b493c9b065a7af7533e718f8623f810e65341a.tar.gz sharkey-77b493c9b065a7af7533e718f8623f810e65341a.tar.bz2 sharkey-77b493c9b065a7af7533e718f8623f810e65341a.zip | |
Use bee-queue instead of Kue
Diffstat (limited to 'src/queue/processors/http/process-inbox.ts')
| -rw-r--r-- | src/queue/processors/http/process-inbox.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/queue/processors/http/process-inbox.ts b/src/queue/processors/http/process-inbox.ts index 7b62f057bc..0738853dd1 100644 --- a/src/queue/processors/http/process-inbox.ts +++ b/src/queue/processors/http/process-inbox.ts @@ -1,4 +1,4 @@ -import * as kue from 'kue'; +import * as bq from 'bee-queue'; import * as debug from 'debug'; const httpSignature = require('http-signature'); @@ -10,7 +10,7 @@ import { resolvePerson } from '../../../remote/activitypub/models/person'; const log = debug('misskey:queue:inbox'); // ユーザーのinboxにアクティビティが届いた時の処理 -export default async (job: kue.Job, done: any): Promise<void> => { +export default async (job: bq.Job, done: any): Promise<void> => { const signature = job.data.signature; const activity = job.data.activity; |