bauer-cluster

Plugin for bauer-cluster to add request/response queue functionality.

Installation

npm install bauer-cluster-queue

Usage

var Cluster = require("bauer-cluster").Cluster;

var myCluster = new Cluster();

myCluster.require("bauer-cluster-queue");

myCluster.master(function() {
  
  var worker = this.fork("one","two");

  var request = worker.request({ ping: true });
  
  request.on("response",function(response) {
    
  });

});

myCluster.worker(function(worker) {

  worker.on("request",function(request,response) {
    if (request.ping) {
      response.send({ pong: true });
    }
  });

});

myCluster.start();

API Summary

• Worker

  • .setupQueue() :void
  • .flush() :void
  • .queue(message Object) :void
  • .request() :Request
  • .request(data Object) :Request
  • .request(data Object, callback Function) :Request

• Request

  • new Request(worker Worker) :Request
  • .send() :void
  • .send(data Object) :void

• Response

  • new Response(worker Worker, id String) :Response
  • .send() :void
  • .send(data Object) :void

License

MIT