node-rabbitrpc
Some modules to require to create producers / consumers using AMQP-RPC
features
- Auto reconnect
- Built on top of amqplib
- Full promise support
how to use it
consumer
listen on a queue and send back a message
//you can also just require('amqprpc')(); if your broker is localvar amqprpc = AMQP_URL: 'amqp://localhost' ;amqprpcconsumer //this create your channels and setup the amqp connexion;
producer
send a message to a queue and listen for a response
//you can also just require('amqprpc')(); if your broker is localvar amqprpc = AMQP_URL: 'amqp://localhost' ;amqprpcproducer;