Fix init of queue workers

2024-01-12 13:18:04 +08:00
parent d98c2c2cf5
commit 273e593a93
1 changed files with 3 additions and 5 deletions
--- a/pkg/bull-queue-admin/index.js
+++ b/pkg/bull-queue-admin/index.js
@ -57,12 +57,10 @@ const run = async () => {
      maxRetriesPerRequest: null,
    }
  }
-  const createQueueMQ = (name) =>
-    new QueueMQ(secrets.REDIS_URL, {
-      connection: redisOptions,
-    })

-  const rssRefreshFeed = createQueueMQ('rssRefreshFeed')
+  const rssRefreshFeed = createQueueMQ('rssRefreshFeed', {
+    connection: redisOptions,
+  })

  const serverAdapter = new ExpressAdapter()
  serverAdapter.setBasePath('/ui')