Bull queue integration in NestJS - Mini Project: Build & Apply

Bull queue integration

📖 Scenario: You are building a NestJS application that needs to process tasks asynchronously using a queue system. Bull is a popular library for managing queues with Redis. You will set up a simple Bull queue to add jobs and process them.

🎯 Goal: Build a NestJS service that integrates Bull queue. You will create a queue, configure it, add jobs to the queue, and process those jobs asynchronously.

📋 What You'll Learn

Create a Bull queue named taskQueue

Configure the queue with Redis connection options

Add a job to the taskQueue with specific data

Process jobs from the taskQueue with a processor function

💡 Why This Matters

🌍 Real World

Queues help handle tasks like sending emails, processing images, or running background jobs without blocking the main app.

💼 Career

Understanding Bull queue integration is essential for backend developers working with NestJS to build scalable and efficient applications.

1

Create the Bull queue instance

Create a Bull queue instance called taskQueue using new Queue('taskQueue') from the bull package.

NestJS

// Create a Bull queue instance named taskQueue
// Your code here

Need a hint?

Import Queue from bull and create a new instance with the name 'taskQueue'.

2

Configure Redis connection for the queue

Add Redis connection options to the taskQueue by passing an object with redis: { host: 'localhost', port: 6379 } when creating the queue.

NestJS

import { Queue } from 'bull';

// Create taskQueue with Redis connection options
// Your code here

Need a hint?

Pass a second argument to new Queue() with the Redis connection details.

3

Add a job to the queue

Use taskQueue.add() to add a job with data { taskId: 1, description: 'Send email' } to the queue.

NestJS

import { Queue } from 'bull';

const taskQueue = new Queue('taskQueue', {
  redis: { host: 'localhost', port: 6379 }
});

// Add a job with taskId 1 and description 'Send email'
// Your code here

Need a hint?

Call add() on taskQueue with the exact data object.

4

Process jobs from the queue

Use taskQueue.process() to define a processor function that receives a job and returns Promise.resolve() after logging the job data.

NestJS

import { Queue } from 'bull';

const taskQueue = new Queue('taskQueue', {
  redis: { host: 'localhost', port: 6379 }
});

taskQueue.add({ taskId: 1, description: 'Send email' });

// Add a processor function to handle jobs
// Your code here

Need a hint?

Use taskQueue.process() with an async function that logs job.data and returns a resolved promise.