message_xpress v0.1.4
messageXpress
Fast, unopinionated, minimalist amqp framework for Node.js. raw message arrived from amqp is wrapped as an http.IncommingMessage, this will help to use 99% of express middlewares already packages
all behavior will act the same as we expect from express framework; because middleware function has the same argument as express, we can handle the same middlewares and the same flows for each route
async / sync
fully support for async middlewares and sync middlewares
error handling
fully support for thrown exception inside middleware.
app.use((req, res, next) => {
next(throw new Error('this is the end'));
})
route.use((req, res, next) => {
// this will triggers only for [YOUR_QUEUE_NAME] route
next(new Error('this is the end'));
})
example
` const app = new Application();
app.use(express.json({limit: '50Mb'})); // this will triggers for all arriving messages
const route = new RouteLayer(YOUR_QUEUE_NAME);
route.use((req, res, next) => { // this will triggers only for YOUR_QUEUE_NAME route next(); })
route.action(ACTION_NAME, (req, res, next) => { console.log(req.body); // will pring the message arrived from amqp next(); }, (req, res, next) => { res.json({success: true}); })
`
listeners
all listeners is sent as a reference
app.on('message_arrive', (rawMsg, ch, req) => {
// TODO: what ever you want
});
app.on('handled', (req, res) => {
// TODO: all data sent with res.json will be waiting in res.body;
});
app.on('error', (err: Error, req) => {
// TODO: err can be of any type extends Error.
// this is the error middleware is sending
})