ritzalam

var amqp = require('amqp')
  , crypto = require('crypto')

var TIMEOUT=2000; //time to wait for response in ms
var CONTENT_TYPE='application/json';
var CONTENT_ENCODING='utf-8';

exports = module.exports = AmqpRpc;

function AmqpRpc(connection){