Skip to content

Rabbitmq Adapter for the eip module. It supports an aggregator Timer using rabbitmq queues.

Notifications You must be signed in to change notification settings

Workable/eip-rabbit

Repository files navigation

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

About

Rabbitmq Adapter for the eip module. It supports an aggregator Timer using rabbitmq queues.

Resources

Stars

Watchers

Forks

Packages

No packages published