File tree Expand file tree Collapse file tree 3 files changed +453
-214
lines changed Expand file tree Collapse file tree 3 files changed +453
-214
lines changed Original file line number Diff line number Diff line change 1
1
const { createBullBoard } = require ( '@bull-board/api' ) ;
2
2
const { BullMQAdapter } = require ( '@bull-board/api/bullMQAdapter' ) ;
3
3
const { ExpressAdapter } = require ( '@bull-board/express' ) ;
4
- const { Queue : QueueMQ , Worker, QueueScheduler } = require ( 'bullmq' ) ;
4
+ const { Queue : QueueMQ , Worker } = require ( 'bullmq' ) ;
5
5
const express = require ( 'express' ) ;
6
6
7
7
const sleep = ( t ) => new Promise ( ( resolve ) => setTimeout ( resolve , t * 1000 ) ) ;
@@ -16,11 +16,6 @@ const redisOptions = {
16
16
const createQueueMQ = ( name ) => new QueueMQ ( name , { connection : redisOptions } ) ;
17
17
18
18
async function setupBullMQProcessor ( queueName ) {
19
- const queueScheduler = new QueueScheduler ( queueName , {
20
- connection : redisOptions ,
21
- } ) ;
22
- await queueScheduler . waitUntilReady ( ) ;
23
-
24
19
new Worker ( queueName , async ( job ) => {
25
20
for ( let i = 0 ; i <= 100 ; i ++ ) {
26
21
await sleep ( Math . random ( ) ) ;
Original file line number Diff line number Diff line change 10
10
"author" : " felixmosh" ,
11
11
"license" : " ISC" ,
12
12
"dependencies" : {
13
- "@bull-board/express" : " ^3.10.4 " ,
14
- "bullmq" : " ^4.6 .0" ,
15
- "express" : " ^4.17.3 "
13
+ "@bull-board/express" : " ^5.9.1 " ,
14
+ "bullmq" : " ^4.14 .0" ,
15
+ "express" : " ^4.18.2 "
16
16
}
17
17
}
You can’t perform that action at this time.
0 commit comments