From 77b493c9b065a7af7533e718f8623f810e65341a Mon Sep 17 00:00:00 2001 From: syuilo Date: Thu, 26 Jul 2018 08:11:47 +0900 Subject: Use bee-queue instead of Kue --- src/queue/processors/http/deliver.ts | 4 ++-- src/queue/processors/http/process-inbox.ts | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) (limited to 'src/queue/processors/http') diff --git a/src/queue/processors/http/deliver.ts b/src/queue/processors/http/deliver.ts index 946d2f65bd..e06866da4e 100644 --- a/src/queue/processors/http/deliver.ts +++ b/src/queue/processors/http/deliver.ts @@ -1,8 +1,8 @@ -import * as kue from 'kue'; +import * as bq from 'bee-queue'; import request from '../../../remote/activitypub/request'; -export default async (job: kue.Job, done: any): Promise => { +export default async (job: bq.Job, done: any): Promise => { try { await request(job.data.user, job.data.to, job.data.content); done(); 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 => { +export default async (job: bq.Job, done: any): Promise => { const signature = job.data.signature; const activity = job.data.activity; -- cgit v1.2.3-freya