publisher.js

var amqp = require('amqp');

var connection = amqp.createConnection({ host: '127.0.0.1' });

// Wait for connection to become established.
connection.on('ready', function () {
  console.log('connection ready');

  //
  connection.exchange('devops', {}, function(exchange) {
    console.log('exchange ready');
    console.log(exchange.name);

    while (true) {
      exchange.publish('log', {from:'test'});
    }
  });

});