Fix instantiation

2024-01-12 13:26:27 +08:00
parent 273e593a93
commit 2f3e2d98d8
2 changed files with 1 additions and 2 deletions
--- a/pkg/bull-queue-admin/index.js
+++ b/pkg/bull-queue-admin/index.js
@ -58,7 +58,7 @@ const run = async () => {
    }
  }

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