ExpressJs — Message Queues with Express

Use message brokers like RabbitMQ or Kafka to enable asynchronous communication between services, preventing bottlenecks in your Express app.

npm install amqplib

const amqp = require('amqplib');

async function sendMessage() {
  const connection = await amqp.connect('amqp://localhost');
  const channel = await connection.createChannel();
  await channel.assertQueue('tasks');
  channel.sendToQueue('tasks', Buffer.from('Process this task'));
  console.log('Message sent');
}

sendMessage();