Rabbit-RPC
amqplib wrapper for easier rabbitmq scripting of RPC interface
Install
npm install @modulus/rabbit-rpc
Usage
RabbitRPC(url, [options])
The exported function takes the same parameters as amqplib.connect,
and returns a object with two exported functions, client and server.
Client(queueName, data, done)
Sends data to queue and yields reply.
const RPC = require('@modulus/rabbit-rpc')(url)
RPC.client('rpc-queue', { message: true }, (err, result) => {
if (err) throw err
console.log(`worker returned ${result}`)
})
Server(queueName, worker, [capacity])
Consumes messages on given queue and passes them to worker. When worker calls done acknowledges the message and sends the result to the client.
const RPC = require('@modulus/rabbit-rpc')(url)
RPC.server('rpc-queue', (msg, done) => {
// do work
done(null, { result: true })
})