Library for reliable message consumption via AMQP protocol.
npm install alpha-amqp-consumer
const connect = ;;
Usage with promises
// (...)manager;// (...)
Every consumer has "resultHandler" which a function that decides what to do with the messages based on the result from consumer function. Message is rejected automatically it consumer function throws an error or returned promise gets rejected, otherwise message is ACKed. You can customize the behavior by providing resultHandler
There is no way to say AMQP to retry message consumption after certain period of time. In order to achieve that we need a bit more typology setup.
For more information how retry works another document.
Run your app with DEBUG env variable. See debug package docs for more details.
DEBUG=alpha-amqp-consumer:* node app.js