File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -10,7 +10,9 @@ const morgan = require('morgan'); // Logging
1010const jwt = require ( 'jsonwebtoken' ) ;
1111const fileUpload = require ( 'express-fileupload' ) ; // File upload support
1212const { setupBullBoard} = require ( './bull-board' ) ;
13- const { setupQueues} = require ( './queue' ) ; // exports { emailQueue, ... }
13+ const { setupQueues, emailQueue,
14+ reportQueue,
15+ graphkbNewUserQueue, } = require ( './queue' ) ; // exports { emailQueue, ... }
1416
1517const conf = require ( './config' ) ;
1618const sequelize = require ( './models' ) ;
@@ -148,7 +150,11 @@ const listen = async (port = null) => {
148150
149151 // bull-mq setup
150152 const queues = setupQueues ( ) ;
151- setupBullBoard ( { app, queues} ) ;
153+ setupBullBoard ( { app, {
154+ emailQueue,
155+ reportQueue,
156+ graphkbNewUserQueue,
157+ } } ) ;
152158
153159 return app ;
154160} ;
Original file line number Diff line number Diff line change @@ -216,7 +216,10 @@ const setupQueues = function () {
216216setupQueues ( ) ;
217217
218218module . exports = {
219- setupQueues,
219+ emailQueue,
220+ reportQueue,
221+ graphkbNewUserQueue,
222+ // setupQueues,
220223 addJobToEmailQueue,
221224 addJobToReportQueue,
222225 addJobToGraphkbNewUserQueue,
You can’t perform that action at this time.
0 commit comments