Node AMQ Message Consumer

gistfile1.js

var queueName = 'tasks';

var amq = require('amq');

var connection = amq.createConnection(
    { host: 'localhost', debug: true },
    { reconnect: { strategy: 'constant', initial: 1000 } }
);

var queue = connection.queue(queueName, { durable: true });
queue.consume(function(message) {
    console.log(message.content.toString());
    queue.ack(message);
}).then(null, console.warn);

Oopsie. Had a little bug in rev 1.