rabbitMQ hapijs plugin
Switch branches/tags
Nothing to show
Clone or download
aduis Merge pull request #6 from JeffreySoriano5/patch-1
Updated example to hapijs 11 of loading plugins
Latest commit a08c5c6 May 29, 2016

README.MD

hapi-rabbit

A simple hapijs plugin to connect to rabbitMQ

Build Status Coverage Status npm version Built with Grunt

NPM

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

npm install hapi-rabbit --save
  • add plugin to hapi server
  • include in your code

Examples

load plugin

server.register([
    {
        register: 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

var Hapi = require('hapi');
var server = new Hapi.Server();
var hapiRabbit = require('hapi-rabbit');

server.connection(
    {
        port: "9090"
    }
);

var plugins = [{
    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);
    }

    var rabbit = 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.