lifeisfoo
2020-11-29 21:51:54
If you're using an express like http server (with middlewares) you can bind the broker to each request object and the use it in your controller code.
This is an example code using express:
your-app.js file:
// import your controller functions
const signup = require('./controller')
let broker = null;
(async () => {
try {
broker = await Broker.create(config);
// your broker setup logic
})();
// your http app setup logic...
app = express();
//add the broker to each request object
app.use((req, res, next) => {
req._broker = broker;
next();
});
app.use('/signup', signup);
controller.js file:
module.exports = (req, res, next) => {
// TODO: your controller logic here
// send the message using the available broker
req._broker.publish('send_email', 'Hello new user!');
next();
});