Node.js MassTransit Listener

masstransit4node.js

var amqp = require('amqp');
 
console.log('create connection');

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

console.log('done');
 
// Wait for connection to become established.
connection.on('ready', function () {
  // Use the default 'amq.topic' exchange
  connection.queue('nodequeue', { durable: false }, function (q) {
      q.bind('blipper','#');
 
      q.subscribe(function (message, headers, deliveryInfo, messageObject) {
	//console.log('----- headers -----');
        //console.log(headers);
	//console.log('----- messageObject -----');
        //console.log(messageObject);

	console.log('----- deliveryInfo -----');
        console.log(deliveryInfo);

	var decoded = JSON.parse(message.data.toString('utf8'));
	console.log('----- decoded -----');
	console.log(decoded);
      });
  });
});