Queue producers in NestJS - Step-by-Step Execution

Concept Flow - Queue producers

Start Producer

↓

Create Job Data

↓

Send Job to Queue

↓

Queue Accepts Job

↓

Job Stored in Queue

↓

Producer Ready for Next Job

The producer creates job data and sends it to the queue, which stores it for consumers.

Execution Sample

NestJS

import { InjectQueue } from '@nestjs/bull';
import { Queue } from 'bull';

constructor(@InjectQueue('email') private emailQueue: Queue) {}

async sendEmailJob(data) {
  await this.emailQueue.add(data);
}

This code shows a NestJS producer adding a job to the 'email' queue.

Execution Table

Step	Action	Job Data	Queue State	Result
1	Producer starts	{}	[]	Ready to send job
2	Create job data	{"to":"[e-mail]","subject":"Hi"}	[]	Job data prepared
3	Add job to queue	{"to":"[e-mail]","subject":"Hi"}	[]	Job sent to queue
4	Queue accepts job	{"to":"[e-mail]","subject":"Hi"}	[{id:1, data:{to:"[e-mail]",subject:"Hi"}}]	Job stored in queue
5	Producer ready for next job	{}	[{id:1, data:{to:"[e-mail]",subject:"Hi"}}]	Waiting for next job

💡 Producer waits for next job after adding current job to queue

Variable Tracker

Variable	Start	After Step 2	After Step 3	After Step 4	Final
jobData	{}	{"to":"[e-mail]","subject":"Hi"}	{"to":"[e-mail]","subject":"Hi"}	{"to":"[e-mail]","subject":"Hi"}	{}
queue	[]	[]	[]	[{id:1, data:{to:"[e-mail]",subject:"Hi"}}]	[{id:1, data:{to:"[e-mail]",subject:"Hi"}}]

Key Moments - 2 Insights

Why does the queue state remain empty right after adding the job?

Because adding a job is asynchronous; the job is sent but not yet stored until the queue processes it, as shown between steps 3 and 4.

What happens to jobData after the job is sent to the queue?

jobData is reset or cleared for the next job, as seen in the final state of the variable_tracker.

Visual Quiz - 3 Questions

Look at the execution table, what is the queue state at step 3?

A Undefined

B Contains one job

C Empty array []

D Null

💡 Hint

Check the 'Queue State' column at step 3 in the execution_table

At which step does the queue actually store the job?

A Step 4

B Step 2

C Step 3

D Step 5

💡 Hint

Look for when the 'Queue State' changes from empty to containing a job

If jobData was not cleared after sending, what would variable_tracker show after step 4?

A jobData becomes null

B jobData remains with job info

C jobData is an empty object

D jobData is undefined

💡 Hint

Compare jobData values before and after step 4 in variable_tracker

Concept Snapshot

NestJS Queue Producers:
- Inject queue with @InjectQueue('name')
- Create job data object
- Use queue.add(data) to send job
- Job is asynchronously stored in queue
- Producer can send multiple jobs sequentially

Full Transcript

In NestJS, a queue producer creates job data and sends it to a queue using the add() method. The queue accepts the job asynchronously and stores it for consumers. The producer then prepares for the next job. Variables like jobData hold the job details before sending, and the queue state updates when the job is stored. This flow ensures jobs are queued efficiently for processing.