test 2

Author: kttkjl

app/index.js

@@ -147,8 +147,7 @@ const listen = async (port = null) => {
   }
 
   // bull-mq setup
-  setupQueues();
-  const queues = Object.values(getReadyQueues());
+  const queues = setupQueues();
   setupBullBoard({app, queues});
 
   return app;

app/queue.js

@@ -194,7 +194,7 @@ const graphkbNewUserProcessor = async (job) => {
 };
 
 const setupQueues = () => {
-  if (!enableQueue) return;
+  if (!enableQueue) return null;
 
   logger.info('Setting up all queues...');
 
@@ -205,15 +205,20 @@ const setupQueues = () => {
   setUpEmailWorker(emailProcessor);
   setUpReportWorker(reportProcessor);
   setUpGraphkbNewUserWorker(graphkbNewUserProcessor);
-};
 
-const getReadyQueues = () => {
-  return ({emailQueue, reportQueue, graphkbNewUserQueue});
+  return ({
+    emailQueue,
+    reportQueue,
+    graphkbNewUserQueue,
+  });
 };
 
+// const getReadyQueues = () => {
+//   return ({emailQueue, reportQueue, graphkbNewUserQueue});
+// };
+
 module.exports = {
   setupQueues,
-  getReadyQueues,
   addJobToEmailQueue,
   addJobToReportQueue,
   addJobToGraphkbNewUserQueue,