nats-hemera
Advanced tools
Comparing version 0.1.53 to 0.1.54
@@ -37,3 +37,3 @@ /*! | ||
ctx.emit('OnPreProcessing', msg) | ||
ctx.emit('onPreProcessing', ctx) | ||
} | ||
@@ -64,3 +64,3 @@ /** | ||
ctx.emit('OnPreResponse', message) | ||
ctx.emit('onPreResponse', ctx) | ||
@@ -67,0 +67,0 @@ } |
@@ -66,3 +66,3 @@ /*! | ||
this.payloadValidator = this._config.payloadValidator || DefaultPayloadValidator | ||
this._payloadValidator = this._config.payloadValidator || DefaultPayloadValidator | ||
@@ -209,2 +209,4 @@ } | ||
let self = this | ||
if (result instanceof Error) { | ||
@@ -270,3 +272,3 @@ | ||
//Validate payload | ||
this.payloadValidator.validate(actMeta.schema, result.value.pattern, (err, value) => { | ||
this._payloadValidator.validate(actMeta.schema, result.value.pattern, (err, value) => { | ||
@@ -497,3 +499,3 @@ if (err) { | ||
this.fatal() | ||
ctx.fatal() | ||
} | ||
@@ -505,3 +507,3 @@ } | ||
//Handle timeout | ||
this.handleTimeout(sid, pattern, cb) | ||
ctx.handleTimeout(sid, pattern, cb) | ||
@@ -508,0 +510,0 @@ } |
{ | ||
"name": "nats-hemera", | ||
"author": "Dustin Deus (https://github.com/StarpTech)", | ||
"version": "0.1.53", | ||
"version": "0.1.54", | ||
"main": "index.js", | ||
@@ -67,4 +67,6 @@ "homepage": "https://hemerajs.github.io/hemera/", | ||
"nats": "0.6.x", | ||
"sinon": "1.17.x" | ||
"sinon": "1.17.x", | ||
"zipkin": "^0.5.0", | ||
"zipkin-transport-http": "^0.5.0" | ||
} | ||
} |
47130
17
991
13