** Redis based Pub/Sub integration into atrix microservice framework**
atrix-pubsub < 4.0.0 works with atrix < 6.0.0
atrix-pubsub >= 4.0.0 works with atrix >= 6.0.0
- Connection setup
- filename based handler registrations
# install atrix
npm install -S @trigo/atrix
# install pubsub plugin
npm install -S @trigo/atrix-pubsub
const Joi = require('joi');
module.exports.descrioption = 'my fancy event handler'
module.exports.schema = joi.object({ ... });
module.exports.handler = async (req, reply, service) => {
console.log(req)
// {
// path: 'my/fancy/event',
// payload: { an: 'event', with: { foo: 'bar' } }
// log: {<logger object>}
// }
// publish another message
await service.publish('other/event', { ... });
}
'use strict';
const atrix = require('@trigo/atrix');
const path = require('path');
atrix.addService({
// name of the service
name: 'pubsub',
// plugin configuration
pubsub: {
// setup redis connection
redis: {
host: 'localhost',
port: 6379,
},
// select which broker to use. allowed: 'redis', 'in-memory' (default)
broker: 'redis',
brokerWildcard: '*', // topic path wildcard. allowed : '*', '%' (default and advised)
// directory containing the handler files
handlerDir: path.join(__dirname, './handlers'),
},
});
// start service
await atrix.services.pubsub.start();
// publish message
await atrix.services.pubsub.publish('my/fancy/topic', { an: 'event', with: { foo: 'bar' } });
![greenkeeper[bot] avatar](https://avatars.githubusercontent.com/in/505?v=4 "greenkeeper[bot]")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent