Queue producers in NestJS - Mini Project: Build & Apply

Queue Producers with NestJS

📖 Scenario: You are building a simple NestJS application that sends messages to a queue system. This is common in real-world apps where tasks are processed asynchronously, like sending emails or processing orders.

🎯 Goal: Create a NestJS queue producer that sends messages to a queue named task_queue. You will set up the data, configure the queue name, implement the message sending logic, and complete the producer service.

📋 What You'll Learn

Create a message object with specific content

Define a queue name variable

Implement a method to send the message to the queue

Complete the NestJS service class with the producer logic

💡 Why This Matters

🌍 Real World

Queue producers are used in applications to send tasks or events to be processed asynchronously, improving performance and user experience.

💼 Career

Understanding how to create queue producers is essential for backend developers working with microservices, event-driven architectures, and scalable systems.

1

Create the message data

Create a constant object called message with the exact properties: { taskId: 101, taskName: 'SendEmail' }.

NestJS

# Create the message object
# Your code here

Need a hint?

Use const to create an object named message with the given properties.

2

Define the queue name

Add a constant string variable called queueName and set it exactly to 'task_queue'.

NestJS

const message = { taskId: 101, taskName: 'SendEmail' };
# Define the queue name
# Your code here

Need a hint?

Use const queueName = 'task_queue'; to define the queue name.

3

Implement the sendMessage method

Inside a NestJS service class, write a method called sendMessage that takes no parameters and calls this.queueClient.send(queueName, message) to send the message.

NestJS

const message = { taskId: 101, taskName: 'SendEmail' };
const queueName = 'task_queue';

export class QueueProducerService {
  constructor(private readonly queueClient: any) {}

  // Implement sendMessage method
  # Your code here
}

Need a hint?

Define sendMessage() method that calls this.queueClient.send(queueName, message);

4

Complete the producer service

Add the @Injectable() decorator above the QueueProducerService class to complete the NestJS service setup.

NestJS

const message = { taskId: 101, taskName: 'SendEmail' };
const queueName = 'task_queue';

// Add @Injectable decorator below
# Your code here
export class QueueProducerService {
  constructor(private readonly queueClient: any) {}

  sendMessage() {
    this.queueClient.send(queueName, message);
  }
}

Need a hint?

Import and add @Injectable() decorator above the class to make it a NestJS service.