bauer-cluster-queue

0.3.10 • Public • Published

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

Package Sidebar

Install

npm i bauer-cluster-queue

Weekly Downloads

2

Version

0.3.10

License

MIT

Last publish

Collaborators

  • yneves