diff --git a/src/index.ts b/src/index.ts index 7545c82c7..9c16c4d22 100644 --- a/src/index.ts +++ b/src/index.ts @@ -79,9 +79,6 @@ async function workerMain() { // start server await require('./server').default(); - // start processor - require('./queue').default(); - // Send a 'ready' message to parent process process.send('ready'); } diff --git a/src/queue/index.ts b/src/queue/index.ts index 775e5f199..e404f6fc9 100644 --- a/src/queue/index.ts +++ b/src/queue/index.ts @@ -1,28 +1,8 @@ -import * as Queue from 'bee-queue'; - -import config from '../config'; import http from './processors/http'; import { ILocalUser } from '../models/user'; -const queue = new Queue('misskey', { - redis: { - port: config.redis.port, - host: config.redis.host, - password: config.redis.pass - }, - - removeOnSuccess: true, - removeOnFailure: true, - getEvents: false, - sendEvents: false, - storeJobs: false -}); - export function createHttpJob(data: any) { - return queue.createJob(data) - //.retries(4) - //.backoff('exponential', 16384) // 16s - .save(); + return http(data, () => {}); } export function deliver(user: ILocalUser, content: any, to: any) { @@ -33,7 +13,3 @@ export function deliver(user: ILocalUser, content: any, to: any) { to }); } - -export default function() { - queue.process(128, http); -}