harcon-amqp
Advanced tools
Comparing version 8.4.0 to 8.4.1
@@ -247,3 +247,3 @@ let _ = require('isa.js') | ||
let packet = JSON.stringify( { id: comm.id, comm: comm, callback: !!comm.callback } ) | ||
let nodeNO = comm.nodeID || self.randomNodeID( comm.valve, comm.division, entityName ) | ||
let nodeNO = self.randomNodeID( comm.valve, comm.division, entityName ) | ||
self.outs[ comm.division ].publish( entityName + (nodeNO ? SEPARATOR + nodeNO : ''), packet, 'utf8') | ||
@@ -265,3 +265,3 @@ return 'ok' | ||
let packet = JSON.stringify( { id: comm.id, comm: comm, err: err ? err.message : null, response: true, responseComms: responseComms || [] } ) | ||
let nodeNO = comm.nodeID || self.randomNodeID( comm.valve, comm.sourceDivision, entityName ) | ||
let nodeNO = comm.sourceNodeID || self.randomNodeID( comm.valve, comm.sourceDivision, entityName ) | ||
self.outs[ comm.sourceDivision ].publish( entityName + (nodeNO ? (SEPARATOR + nodeNO) : ''), packet, 'utf8') | ||
@@ -268,0 +268,0 @@ return 'ok' |
{ | ||
"name": "harcon-amqp", | ||
"version": "8.4.0", | ||
"version": "8.4.1", | ||
"description": "AMQP plugin for the harcon messaging/service bus of node-based enterprise entities.", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
20051