Comparing version 1.4.7 to 1.4.8
@@ -361,3 +361,3 @@ let NATS = require('nats') | ||
delete self.chunks[ key ] | ||
callbackFn( BaseErrors.RequestTimeout( { entity, message, tolerance: self.reponseTolerance } ) ) | ||
callbackFn( BaseErrors.RequestTimeout( { entity, message, tolerance: self.reponseTolerance } ) ) | ||
} | ||
@@ -492,2 +492,12 @@ } | ||
return this.innercomm(mode, flowID, processID, GATER, this.nodeID, entity, message, null, null, params, terms) | ||
}, | ||
async inform (flowID, entity, message, params, terms) { | ||
return this.innercomm(MODE_INFORM, flowID, '', GATER, this.nodeID, entity, message, null, null, params, terms) | ||
}, | ||
async delegate (flowID, entity, message, params, terms) { | ||
return this.innercomm(MODE_DELEGATE, flowID, '', GATER, this.nodeID, entity, message, null, null, params, terms) | ||
}, | ||
async request (flowID, entity, message, params, terms) { | ||
return this.innercomm(MODE_REQUEST, flowID, '', GATER, this.nodeID, entity, message, null, null, params, terms) | ||
} | ||
@@ -494,0 +504,0 @@ |
{ | ||
"name": "darcon", | ||
"version": "1.4.7", | ||
"version": "1.4.8", | ||
"description": "Simple Messaging/Service Bus for node entities over NatsIO", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
57868
1348