GITS RabbitRPC Server

by: kumangxxx
visit the repo

This is a simple helper library to manage your RabbitMQ RPC Server. It make use of RabbitMQ 'topic' exchange.

Installation

``
$ npm install --save gits-rabbit-rpc-server
`

How to use

`
const server = require('gits-rabbit-rpc-server');
...
server.handleRoute('user.api.all', function(stringBody, callback) {
var users = [{id: 0, email: 'someemail'}];
callback(null, JSON.stringify(users)); // --> callback result must be a string
});
...
server.start('amqps://user:password@host', 'queue_name', max_connection, function(err) {
rabbit_server.declareExchange({name: 'rpc_service', type: 'topic', durable: true});
rabbit_server.bindExchangeToQueue({routingKey: 'rpc.api.test'});
console.log('RabbitMQ RPC Server is running');
});

``