bauer-cluster-queue

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