Skip to content

Devisjs/devis_rabbitmq

Folders and files

NameName
Last commit message
Last commit date

Latest commit

3b50e81 · Nov 25, 2017

History

12 Commits
Nov 25, 2017
Nov 25, 2017
Nov 25, 2017
Nov 25, 2017
Nov 25, 2017
Nov 25, 2017
Nov 25, 2017
Nov 25, 2017

Repository files navigation

Devis rabbitMQ transport

An amqp transport plugin for Devis

Install

    $ npm install --save devis
    $ npm install --save devis_rabbitmq

Example

  • Server.js
const devis = require("devis")
    .plug("devis_rabbitmq");

const rabbitOptions = {
    host: "localhost",
    port: 5672,
    queue: "1x"
}

devis.push({ method: "calculator", action: "add" }, (args, done) => {
    done(null, args.ar1 + args.ar2);
});

devis.listenMQ({ rabbitmq: rabbitOptions }, (err, res) => {
    if (err) console.log(err);
});
  • Client.js
const devis = require("devis")
    .plug("devis_rabbitmq");

const rabbitOptions = {
    host: "localhost",
    port: 5672,
    queue: "1x"
}

const promise = new Promise((resolve, reject) => {
    devis.clientMQ({ rabbitmq: rabbitOptions }, (err, res) => {
        if (err) reject(err);
        else {
            resolve(res);
        }
    });
});

promise.then((result) => {
    devis.callMQ({ queue: "1x", method: "calculator", action: "add" }, { ar1: 1, ar2: 2 }, (err, res) => {
        console.log(res);
    })
});

About

Amqp transport plugin for Devis

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published