RabbitMQ Message Queues: Patterns and Implementation

const amqp = require('amqplib');

async function sendMessage() {
    const connection = await amqp.connect('amqp://localhost');
    const channel = await connection.createChannel();
    
    const queue = 'tasks';
    const message = 'Hello RabbitMQ!';
    
    await channel.assertQueue(queue, { durable: true });
    channel.sendToQueue(queue, Buffer.from(message), {
        persistent: true
    });
    
    console.log("Sent:", message);
    await channel.close();
    await connection.close();
}

async function receiveMessage() {
    const connection = await amqp.connect('amqp://localhost');
    const channel = await connection.createChannel();
    
    const queue = 'tasks';
    await channel.assertQueue(queue, { durable: true });
    
    channel.consume(queue, (msg) => {
        if (msg) {
            console.log("Received:", msg.content.toString());
            channel.ack(msg);
        }
    });
}

// Distribute tasks among workers
channel.prefetch(1); // Fair dispatch

// Exchange for broadcasting
await channel.assertExchange('logs', 'fanout', { durable: false });
channel.publish('logs', '', Buffer.from(message));