@bull-board/ui

Queue Monitoring

This code sets up a basic Express server with a Bull queue and integrates the @bull-board/ui to provide a web-based dashboard for monitoring the queue.

const { createBullBoard } = require('@bull-board/api');
const { BullAdapter } = require('@bull-board/api/bullAdapter');
const { ExpressAdapter } = require('@bull-board/express');
const Queue = require('bull');

const someQueue = new Queue('someQueueName');
const serverAdapter = new ExpressAdapter();
serverAdapter.setBasePath('/admin/queues');

createBullBoard({
  queues: [new BullAdapter(someQueue)],
  serverAdapter: serverAdapter
});

const app = require('express')();
app.use('/admin/queues', serverAdapter.getRouter());
app.listen(3000, () => {
  console.log('Running on 3000...');
});

Job Management

This code demonstrates how to add a job to a Bull queue and monitor it using the @bull-board/ui dashboard.

const { createBullBoard } = require('@bull-board/api');
const { BullAdapter } = require('@bull-board/api/bullAdapter');
const { ExpressAdapter } = require('@bull-board/express');
const Queue = require('bull');

const someQueue = new Queue('someQueueName');
const serverAdapter = new ExpressAdapter();
serverAdapter.setBasePath('/admin/queues');

createBullBoard({
  queues: [new BullAdapter(someQueue)],
  serverAdapter: serverAdapter
});

const app = require('express')();
app.use('/admin/queues', serverAdapter.getRouter());
app.listen(3000, () => {
  console.log('Running on 3000...');
});

// Adding a job to the queue
someQueue.add({ foo: 'bar' });

Job Status Visualization

This code shows how to process jobs in a Bull queue and visualize their status using the @bull-board/ui dashboard.

const { createBullBoard } = require('@bull-board/api');
const { BullAdapter } = require('@bull-board/api/bullAdapter');
const { ExpressAdapter } = require('@bull-board/express');
const Queue = require('bull');

const someQueue = new Queue('someQueueName');
const serverAdapter = new ExpressAdapter();
serverAdapter.setBasePath('/admin/queues');

createBullBoard({
  queues: [new BullAdapter(someQueue)],
  serverAdapter: serverAdapter
});

const app = require('express')();
app.use('/admin/queues', serverAdapter.getRouter());
app.listen(3000, () => {
  console.log('Running on 3000...');
});

// Adding a job to the queue
someQueue.add({ foo: 'bar' });

// Processing jobs
someQueue.process(async (job) => {
  console.log('Processing job:', job.data);
  return Promise.resolve();
});