egg-mq
Install
$ npm i egg-mq --save
Usage
exports.mq = {
enable: true,
package: 'egg-mq',
};
Configuration
const mq = require('./mq.json');
exports.mq = {
rabbitmq: { address, port, username, password },
...mq
};
{
"producers": [
{
"exchange": "eggmqproducer.exchange.message",
"exchangeType": "topic"
}
],
"consumers": [
{
"exchange": "eggmqproducer.exchange.message",
"exchangeType": "topic",
"queue": "eggmqconsumer.queue.textMessage",
"topic": "text.*",
"consumer": "foo.bar"
}
]
}
Example
ctx.service.mq.producer('some.exchange', 'some.topic', payload);
async consumer(topic, payload) {
ctx.logger.info(payload);
}
Questions & Suggestions
Please open an issue here.
License
MIT