amq

A nodejs AMQP implementation built on top of amqplib's channel-oriented api. Connection/Queue/Exchange constructors supporting auto-reconnection and backoff.

Examples

Connection

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

Some quick examples

    
    var queue = connection.queue( 'someName' , { durable : true }) ;
    // auto generated queue name, exclusive to conn
    var queue = connection.queue( '' , { exclusive : true }) ;
    var exchange = connection.exchange('myExchange',{durable:true,type:'fanout',confirm:true});
    queue.bind(exchange).then(function(){
        return exchange.publish('foo',{deliveryMode:true,mandatory:true, etc...},function confirmCb(){}).then(function(){
            // written to socket.
        })
    }).then(null,handleErr)
    
    queue.bind('exgName').then(function(){
        ...
    }).then(null,handleErr)
    queue.unbind('exgName').then(function(){
        ...
    }).then(null,handleErr)
    
    queue.consume(function(message){
        // queue.ack(message);
        // que.nack(message);
        // queue.recover()
    }).then(function(subscription){
        // return connection.sendToQueue(queueName,'foo')
        // return queue.publish(message,opts,cbIfConfirmMode)
    }).then(null,done)
 
    queue.consume({ prefetch : 1, noLocal : true , etc.. },function(message){
        // queue.ack(message);
        // que.nack(message);
        // queue.recover()
    }).then(function(subscription){
        // return connection.sendToQueue(queueName,'foo')
        // return queue.publish(message,opts,cbIfConfirmMode)
    }).then(null,done)
 
    // cancel a consumer 	
    queue.consume(fn).then(function(subscription){
        return queue.cancel(subscription.consumerTag)
    }).then(null,done)
 
    // basick get
    queue.publish('foo').then(function(){
        return queue.get({opts...}).then(function(message){
            // will either get a message or 'false'
        })
    }).then(null,done);
    
    // destroy
    queue.destroy().then(function(){
        queue.check().then(null,assert.ifError).then(null,done.bind(null,null));
    }).then(null,done)