Comparing version 2.0.0-beta.10 to 2.0.0-beta.11
21
index.js
@@ -5,3 +5,2 @@ const packageJson = require('./package.json') | ||
const Response = require('./lib/Response') | ||
const aliases = require('./resources/aliases') | ||
const connect = require('./lib/assertions/connection') | ||
@@ -27,11 +26,16 @@ const bootWorkChannelPool = require('./lib/assertions/bootWorkChannelPool') | ||
this.request = Request.apply(this, [{ | ||
this.request = | ||
this.requestOne = | ||
this.req = Request.apply(this, [{ | ||
expectReply: true | ||
}]) | ||
this.emit = Request.apply(this, [{ | ||
this.emit = | ||
this.publish = Request.apply(this, [{ | ||
expectReply: false | ||
}]) | ||
this.respond = Response.apply(this, [{ | ||
this.respond = | ||
this.res = | ||
this.endpoint = Response.apply(this, [{ | ||
shouldAck: false, | ||
@@ -41,3 +45,4 @@ shouldReply: true | ||
this.listen = Response.apply(this, [{ | ||
this.listen = | ||
this.on = Response.apply(this, [{ | ||
shouldAck: true, | ||
@@ -53,8 +58,2 @@ shouldReply: false, | ||
Object.keys(aliases).forEach((key) => { | ||
aliases[key].forEach((alias) => { | ||
this[alias] = this[key] | ||
}) | ||
}) | ||
connect.apply(this, [this._options]) | ||
@@ -61,0 +60,0 @@ this._workChannelPool = bootWorkChannelPool.apply(this) |
@@ -168,3 +168,3 @@ const debug = require('debug')('remit:request') | ||
request._emitter.emit(`timeout-${messageId}`, timeoutOpts) | ||
}, 30000) | ||
}, localOpts.timeout || 30000) | ||
} | ||
@@ -171,0 +171,0 @@ |
{ | ||
"name": "remit", | ||
"version": "2.0.0-beta.10", | ||
"version": "2.0.0-beta.11", | ||
"description": "A small set of functionality used to create microservices that don't need to be aware of one-another's existence.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
43202
20
969