A Seneca.js Event and Message Muxing Plugin
Lead Maintainers: Tobias Gurtzick and Christian Wolf
This module is a plugin for the Seneca framework. It provides muxing capabilities to combine different messages and events into a single event that an indefinite amount of clients listens to. This helps when synchronizing asynchronous actions coming from across your microservice landscape.
To use the muxer first install the module via
npm i -s seneca-muxer
Next you will need a driver, for example a redis driver:
npm i -s seneca-muxer-redis
Now you can require the plugin and use it, like in the following example:
'use strict';
const seneca = require('seneca');
seneca.use('muxer', {
driver: 'seneca-muxer-redis'
});
seneca.act('muxer:register', {
events: [
'simple:event',
'another:event'
],
optionalEvents: [
'event:that,is:optional'
],
fires: 'on:fire',
maxRequestTime: 2000
});