瀏覽代碼

change number of queue processors

Pouria Ezzati 1 年之前
父節點
當前提交
06bbf16af0
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      server/queues/queues.js

+ 1 - 1
server/queues/queues.js

@@ -12,7 +12,7 @@ const redis = {
 
 const visit = new Queue("visit", { redis });
 visit.clean(5000, "completed");
-visit.process(8, path.resolve(__dirname, "visit.js"));
+visit.process(6, path.resolve(__dirname, "visit.js"));
 visit.on("completed", job => job.remove());
 
 // TODO: handler error