Benature/omnivore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Clean up

Browse Source
This commit is contained in:
Jackson Harper
2024-01-12 21:36:33 +08:00
parent b136d5c4bc
commit 362f87bb09
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/bull-queue-admin/index.js
View File

@ -1,7 +1,7 @@
const { createBullBoard } = require('@bull-board/api')
const { BullMQAdapter } = require('@bull-board/api/bullMQAdapter')
const { ExpressAdapter } = require('@bull-board/express')
const { Queue: QueueMQ, Worker } = require('bullmq')
const { Queue } = require('bullmq')
const { Redis } = require('ioredis')
const session = require('express-session')
const bodyParser = require('body-parser')
@ -59,7 +59,9 @@ const run = async () => {
}
}
const connection = new Redis(secrets.REDIS_URL, {
const connection = new Redis({
host: secrets.REDIS_HOST,
port: secrets.REDIS_PORT,
tls: {
cert: secrets.REDIS_CERT,
rejectUnauthorized: false,
@ -68,7 +70,7 @@ const run = async () => {
})
console.log('set connection: ', connection)
const rssRefreshFeed = new QueueMQ('rssRefreshFeed', {
const rssRefreshFeed = new Queue('rssRefreshFeed', {
connection: connection,
})