amqplib-rabbitmq-pub-sub

RabbitMQ Publisher & Subscriber

Publisher

const { Publisher, Subscriber } = require('amqplib-rabbitmq-pub-sub')

const publisherOptions = {
    exchange: 'command',
    type: 'topic',
    url: 'amqp://localhost'
};
const publisher = new Publisher(publisherOptions);
const startMessaging = async () => {
    try {
        await publisher.start()
        console.log(['rabbitmq', 'connected']);
        for (let index = 0; index < 2; index++) {
            publisher.publish('key', JSON.stringify({ index, timestamp: new Date() }));
        }
    } catch (error) {
        console.error(error)
    }
}
startMessaging()

Subscriber

const subscriberOptions = {
    exchange: 'command',
    queueName: 'command',
    routingKeys: ['key']
};
const subscriber = new Subscriber(subscriberOptions);
const onIncomingMessage = (message) => {
    console.log('onIncomingMessage', message.content.toString());
    subscriber.ack(message);
};
subscriber.start(onIncomingMessage)