Comparing version 1.4.5 to 1.4.6
@@ -165,10 +165,10 @@ let NATS = require('nats') | ||
processID: incoming.comm.processID, | ||
async request (to, message, params, _terms) { | ||
return self.innercomm(MODE_REQUEST, incoming.comm.flowID, incoming.comm.processID, incoming.comm.entity, self.nodeID, to, message, null, null, params, assigner.assign( {}, terms, _terms)) | ||
async request (to, message, params) { | ||
return self.innercomm(MODE_REQUEST, incoming.comm.flowID, incoming.comm.processID, incoming.comm.entity, self.nodeID, to, message, null, null, params, terms ) | ||
}, | ||
async inform (to, message, params, _terms) { | ||
return self.innercomm(MODE_INFORM, incoming.comm.flowID, incoming.comm.processID, incoming.comm.entity, self.nodeID, to, message, null, null, params, assigner.assign( {}, terms, _terms)) | ||
async inform (to, message, params) { | ||
return self.innercomm(MODE_INFORM, incoming.comm.flowID, incoming.comm.processID, incoming.comm.entity, self.nodeID, to, message, null, null, params, terms ) | ||
}, | ||
async delegate (to, message, delegateEntity, delegateMessage, params, _terms) { | ||
return self.innercomm(MODE_DELEGATE, incoming.comm.flowID, incoming.comm.processID, incoming.comm.entity, self.nodeID, to, message, delegateEntity, delegateMessage, params, assigner.assign( {}, terms, _terms)) | ||
async delegate (to, message, delegateEntity, delegateMessage, params) { | ||
return self.innercomm(MODE_DELEGATE, incoming.comm.flowID, incoming.comm.processID, incoming.comm.entity, self.nodeID, to, message, delegateEntity, delegateMessage, params, terms ) | ||
}, | ||
@@ -175,0 +175,0 @@ comm: incoming.comm |
{ | ||
"name": "darcon", | ||
"version": "1.4.5", | ||
"version": "1.4.6", | ||
"description": "Simple Messaging/Service Bus for node entities over NatsIO", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
57228