rabbitmq-rpc-eventemitter
Simplified rabbitmq RPC using rabbitmq-eventemitter version 1.3.1 and above.
npm install rabbitmq-rpc-eventemitter
Usage
The constructor accepts an rabbitmq-eventemitter object. The returned instance exposes a pull method for receiving and a push method for sending requests.
var queue = require('rabbitmq-eventemitter')('amqp://localhost');
var rpc = require('rabbitmq-rpc-eventemitter')(queue);
rpc.pull('get.instance', function(message, callback) {
console.log(message); // prints { request: 1 }
callback(null, { response: 1 });
});
rpc.push('get.instance', { request: 1 }, function(err, message) {
console.log(message); // prints { response: 1 }
});
