lib/service.js
function Service(bus, name) {
  events.EventEmitter.call(this);
  this.bus = bus;
  this.name = name;
  this.logger = bus.logger.withTag(name);
  this.type = "service";
  this.id = "service:" + name;
  this.replyTo = this.id + ":replyTo:" + crypto.randomBytes(8).toString("hex");
  this.pendingReplies = {};
  this.requesters = {};
  this.inflight = 0;
}
function Service(bus, name) {
  events.EventEmitter.call(this);
  this.bus = bus;
  this.name = name;
  this.logger = bus.logger.withTag(name);
  this.type = "service";
  this.id = "service:" + name;
  this.replyTo = this.id + ":replyTo:" + crypto.randomBytes(8).toString("hex");
  this.pendingReplies = {};
  this.requesters = {};
  this.inflight = 0;
}
function Service ( bus , name ) { events . EventEmitter . call ( this ) ; this . bus = bus ; this . name = name ; this . logger = bus . logger . withTag ( name ) ; this . type = "service" ; this . id = "service:" + name ; this . replyTo = this . id + ":replyTo:" + crypto . randomBytes ( 8 ) . toString ( "hex" ) ; this . pendingReplies = { } ; this . requesters = { } ; this . inflight = 0 ; }
Creates a new service endpoint utilizing message queues
@param bus
@param name the service name
@constructor
Creates a new service endpoint utilizing message queues