pubsub-publisher.js

const amqp = require('..');
const {wait} = require('../lib/helpers');

const EXCHANGE_NAME = 'amqp-connection-manager-sample2-ex';

// Create a connetion manager
const connection = amqp.connect(['amqp://localhost']);
connection.on('connect', () => console.log('Connected!'));
connection.on('disconnect', err => console.log('Disconnected.', err.stack));

// Create a channel wrapper
const channelWrapper = connection.createChannel({
    json: true,
    setup: channel => channel.assertExchange(EXCHANGE_NAME, 'topic')
});

// Send messages until someone hits CTRL-C or something goes wrong...
function sendMessage() {
    channelWrapper.publish(EXCHANGE_NAME, "test", {time: Date.now()}, { contentType: 'application/json', persistent: true })
    .then(function() {
        console.log("Message sent");
        return wait(1000);
    })
    .then(() => sendMessage())
    .catch(err => {
        console.log("Message was rejected:", err.stack);
        channelWrapper.close();
        connection.close();
    });
};

console.log("Sending messages...");
sendMessage();