diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/index.ts | 3 | ||||
| -rw-r--r-- | src/queue/index.ts | 26 |
2 files changed, 1 insertions, 28 deletions
diff --git a/src/index.ts b/src/index.ts index 7545c82c74..9c16c4d223 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 775e5f199d..e404f6fc9c 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); -} |