hapi-rabbit
A simple hapijs plugin to connect to rabbitMQ
Introduction
hapi-rabbit basically wraps rabbit.js and gives the user a simple api to publish and subscribe to rabbitMQ
Prerequisites
Installation
npm install hapi-rabbit --save
- add plugin to hapi server
- include in your code
Examples
load plugin
plugin.register([
{
plugin: require('hapi-rabbit'),
options: {
url: 'amqp://localhost'
}
}
], function (err) {
if (err) {
throw err;
}
});
publish a message
function (request, reply) {
var rabbit = request.server.plugins['hapi-rabbit'];
rabbit.createContext(function(err, context){
if(err){
console.log('err', err);
}
rabbit.publish(context, 'exchange', 'messageType', 'message', function(err, data){
console.log('messageObject', data);
});
});
reply('Hello!');
}
subscribe
exports.register = function (plugin, options, next) {
plugin.events.once('start', function () {
var rabbit = plugin.plugins['hapi-rabbit'];
rabbit.createContext(function(err, context){
if(err){
console.log('err', err);
}
rabbit.subscribe(context, 'exchange', function(err, message){
console.log('message', message);
});
});
});
next();
};
Contribute
If you want to contribute to hapi-rabbit, please send me a pull request.