prehistoric-systems/omnivore
1
0
Fork 0
mirror of https://github.com/omnivore-app/omnivore.git synced 2026-03-11 08:54:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update queue admin

Browse source
This commit is contained in:
Hongbo Wu 2024-08-21 14:46:24 +08:00
parent 03ff18af81
commit 2ada017427
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pkg/bull-queue-admin/index.js
View file

@ -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,
})