バギーなのでジョブキュー無効化

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);
-}