Core Concepts

Exchange Types

Node.js Example

const amqp = require('amqplib');

// Publisher
const connection = await amqp.connect('amqp://localhost');
const channel = await connection.createChannel();
await channel.assertQueue('tasks');
channel.sendToQueue('tasks', Buffer.from('Hello'));

// Consumer
channel.consume('tasks', (msg) => {
  console.log(msg.content.toString());
  channel.ack(msg);
});

Best Practices

• Use acknowledgements for reliability
• Set message TTL to avoid queue bloat
• Use dead letter exchanges for failures
• Monitor queue length and consumer rate