bunnydo

    0.1.0 • Public • Published

    bunnydo

    Wrapper around amqplib to make common patterns easier.

    Still work in progress. Will document more thoroughly soon. Might change and expand.

    Basic usage:

    var Bunnydo = require('bunnydo');
     
    var amqp = new Bunnydo('amqp://localhost');
    amqp.init(function (err) {
     
      amqp.worker('work_queue', 'something to do', function (err) {
        // sent to work queue
      });
     
      amqp.rpc('rpc_queue', 'something to do', function (err, rpcRes) {
        console.dir(rpcRes); // response from RPC worker
      });
     
      amqp.pubsub('pubsub_queue', 'something to do', function (err) {
        // send to pubsub
      });
    });
     
     
     

    Then on the other end:

    var Bunnydo = require('bunnydo');
     
    var amqp = new Bunnydo('amqp://localhost');
    amqp.init(function (err) {
     
      amqp.onWorker('work_queue', function (err, msg) {
        console.log("Worker received '%s'", msg);
      });
     
      amqp.onRpc('rpc_queue', function (err, msg, replyFn) {
        console.log("RPC received '%s'", msg);
        replyFn(msg.toUpperCase());
      });
     
      amqp.onPubsub('pubsub_queue', function (err, msg) {
        console.log("pubsub received '%s'", msg);
      });
     
    });

    Examples of use can be seen here.

    Keywords

    Install

    npm i bunnydo

    DownloadsWeekly Downloads

    39

    Version

    0.1.0

    License

    MIT

    Last publish

    Collaborators

    • bojand