Connects to RabbitMQ's log exchange and logs all received messages to the console

rabbit.js

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

connection.on('ready', function() {
	// create a temporary queue by passing an empty string as the queue name
	var queue = connection.queue('', function(queue) {
		
		console.log('connected to ' + queue.name);

		// bind the queue to all messages on the amq.rabbitmq.log topic exchange
		queue.bind('amq.rabbitmq.log', '#');

		// log messages to the console
		queue.subscribe(function(message, headers, deliveryInfo) {
			console.log('[' + deliveryInfo.routingKey + '] ' + message.data.toString());
		});
	});
});