diff options
Diffstat (limited to 'src/queue/index.ts')
| -rw-r--r-- | src/queue/index.ts | 26 |
1 files changed, 1 insertions, 25 deletions
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); -} |