eip-rabbit

Enterprise Integration Patterns for javascript rabbitmq adapter.

Create a Timer for the eip aggregator that uses rabbitmq to implement the timeout.

Installation

npm install --save eip-rabbit

Usage

const eip = require('eip');
const { Rabbit } = require('rabbit-queue');
const rabbit = new Rabbit('amqp://localhost', { scheduledPublish: true }); // scheduledPublish must be enabled
const { Timer } = require('eip-rabbit');
const timer = new Timer([1000, 5000], rabbit, 'timer') // delays in ms
const aggregator = new eip.Route().aggregate({ timer });

License

MIT