From 2ada017427f8e6ebae503989eb8babef86bcc6d9 Mon Sep 17 00:00:00 2001 From: Hongbo Wu Date: Wed, 21 Aug 2024 14:46:24 +0800 Subject: [PATCH] update queue admin --- pkg/bull-queue-admin/index.js | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/pkg/bull-queue-admin/index.js b/pkg/bull-queue-admin/index.js index fee71ed8f..49b275ec3 100644 --- a/pkg/bull-queue-admin/index.js +++ b/pkg/bull-queue-admin/index.js @@ -59,7 +59,10 @@ const run = async () => { const connection = new Redis(secrets.REDIS_URL, redisOptions(secrets)) console.log('set connection: ', connection) - const rssRefreshFeed = new Queue('omnivore-backend-queue', { + const backendQueue = new Queue('omnivore-backend-queue', { + connection: connection, + }) + const contentFetchQueue = new Queue('omnivore-content-fetch-queue', { connection: connection, }) @@ -67,7 +70,10 @@ const run = async () => { serverAdapter.setBasePath('/ui') createBullBoard({ - queues: [new BullMQAdapter(rssRefreshFeed)], + queues: [ + new BullMQAdapter(backendQueue), + new BullMQAdapter(contentFetchQueue), + ], serverAdapter, })