consumer.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');

  // Use the default 'amq.topic' exchange
  connection.queue('logger', function(q){
    console.log('queue ready');
    // Bind this queue to exchange 'devops' with route key 'log'
    q.bind('devops','log');

    //console.log(q);

    // Receive messages
    q.subscribe(function (message) {
      // Print messages to stdout
      console.log(message);
    });
  });
});