Initialize queue only if queue is enabled (#4125)

1 files changed, 20 insertions, 12 deletions

diff --git a/src/queue/index.ts b/src/queue/index.ts
index d1237435be..65c52d864c 100644
--- a/src/queue/index.ts
+++ b/src/queue/index.ts
@@ -7,19 +7,27 @@ import { program } from '../argv';
 
 const enableQueue = config.redis != null && !program.disableQueue;
 
-const queue = new Queue('misskey', {
-	redis: {
-		port: config.redis.port,
-		host: config.redis.host,
-		password: config.redis.pass
-	},
+const queue = initializeQueue();
 
-	removeOnSuccess: true,
-	removeOnFailure: true,
-	getEvents: false,
-	sendEvents: false,
-	storeJobs: false
-});
+function initializeQueue() {
+	if (enableQueue) {
+		return 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
+		});
+	} else {
+		return null;
+	}
+}
 
 export function createHttpJob(data: any) {
 	if (enableQueue) {