summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/index.ts26
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);
-}