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

• RabbitMQ
• Node.js
• Hapi.js

Installation

npminstallhapi-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){throwerr;}});

publish a message

function(request,reply){varrabbit=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

varHapi=require('hapi');varserver=newHapi.Server();varhapiRabbit=require('hapi-rabbit');server.connection({port: "9090"});varplugins=[{{register: hapiRabbit,options: {url: "amqp://localhost"}}];server.register(plugins,function(err){if(err){console.log('error when registering modules',error);}});server.start(function(err){if(err){console.log('error when starting server',error);}varrabbit=server.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);});});console.log('service started');});

Contribute

If you want to contribute to hapi-rabbit, please send me a pull request.