chore(worker): disable bullboard as an option
This commit is contained in:
@@ -16,23 +16,25 @@ import { bootWorkers } from './boot-workers';
|
|||||||
import { register } from './metrics';
|
import { register } from './metrics';
|
||||||
import { logger } from './utils/logger';
|
import { logger } from './utils/logger';
|
||||||
|
|
||||||
const PORT = Number.parseInt(process.env.WORKER_PORT || '3000', 10);
|
|
||||||
const serverAdapter = new ExpressAdapter();
|
|
||||||
serverAdapter.setBasePath('/');
|
|
||||||
const app = express();
|
|
||||||
|
|
||||||
async function start() {
|
async function start() {
|
||||||
createBullBoard({
|
const PORT = Number.parseInt(process.env.WORKER_PORT || '3000', 10);
|
||||||
queues: [
|
const app = express();
|
||||||
new BullMQAdapter(eventsQueue),
|
|
||||||
new BullMQAdapter(sessionsQueue),
|
|
||||||
new BullMQAdapter(cronQueue),
|
|
||||||
new BullMQAdapter(notificationQueue),
|
|
||||||
],
|
|
||||||
serverAdapter: serverAdapter,
|
|
||||||
});
|
|
||||||
|
|
||||||
app.use('/', serverAdapter.getRouter());
|
if (process.env.DISABLE_BULLBOARD === undefined) {
|
||||||
|
const serverAdapter = new ExpressAdapter();
|
||||||
|
serverAdapter.setBasePath('/');
|
||||||
|
createBullBoard({
|
||||||
|
queues: [
|
||||||
|
new BullMQAdapter(eventsQueue),
|
||||||
|
new BullMQAdapter(sessionsQueue),
|
||||||
|
new BullMQAdapter(cronQueue),
|
||||||
|
new BullMQAdapter(notificationQueue),
|
||||||
|
],
|
||||||
|
serverAdapter: serverAdapter,
|
||||||
|
});
|
||||||
|
|
||||||
|
app.use('/', serverAdapter.getRouter());
|
||||||
|
}
|
||||||
|
|
||||||
app.get('/metrics', (req, res) => {
|
app.get('/metrics', (req, res) => {
|
||||||
res.set('Content-Type', register.contentType);
|
res.set('Content-Type', register.contentType);
|
||||||
|
|||||||
Reference in New Issue
Block a user