Skip to content

Instantly share code, notes, and snippets.

@jig
jig / amqprpc.js
Created October 26, 2012 13:48 — forked from kmpm/amqprpc.js
RPC over RabbitMQ/AMQP
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){