node-pm2-events
Advanced tools
Comparing version 1.2.36 to 1.2.37
{ | ||
"name": "node-pm2-events", | ||
"version": "1.2.36", | ||
"version": "1.2.37", | ||
"description": "EventBus for local and decentralized instances of the both for individual nodejs applications and as parts of pm2", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -256,2 +256,3 @@ /* | ||
) return; | ||
console.log('transport on callback', channel, message) | ||
callback(ch, message.data); | ||
@@ -279,2 +280,3 @@ } catch (e) { | ||
}); | ||
console.log('transport send', channel, message) | ||
this.#publisher.publish(channel, message); | ||
@@ -281,0 +283,0 @@ } |
@@ -43,2 +43,3 @@ /* | ||
this.EventBus.on(channel, (message) => { | ||
console.log('ws catch internal', channel, message) | ||
this.send(message); // catch internal event and send broadcast to connected clients | ||
@@ -77,2 +78,3 @@ this.EventBus.transport.send(channel, message); // send to other server instances | ||
message = this.stringify(message); | ||
console.log('ws send', message) | ||
for (let connection of this.#connections.values()) try { | ||
@@ -79,0 +81,0 @@ connection.socket.send(message); |
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
38175
813