node-pm2-events - npm Package Compare versions

Comparing version 1.3.3 to 1.3.4

package.json

		{
		"name": "node-pm2-events",
		"version": "1.3.3",
		"version": "1.3.4",
		"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",

src/EventBus/Transport.js

		@@ -206,4 +206,6 @@ /*
		message = parse(message);
		// self message confirmed
		if (this.#notConfirmedMessage(message)) return;
		if (message.data.type === this.constant.type.iamhere) this.#setIsPrimary(message.sender.id);
		// self message are not confirmed
		if (message.data.type === this.constant.type.bye && !this.isSameId(message.sender.id)) _send(this.constant.type.iamhere);
		@@ -286,4 +288,3 @@ } catch (e) {
		#notConfirmedMessage(message) {
		return this.isSameId(message.sender.id) \|\|
		(this.#filterByProcessName && !this.isSameProcessName(message.sender.process_name)) \|\|
		return (this.#filterByProcessName && !this.isSameProcessName(message.sender.process_name)) \|\|
		this.#excludeAddress.has(message.sender.address)
		@@ -304,3 +305,3 @@ }
		message = parse(message);
		if (this.#notConfirmedMessage(message)) return;
		if (this.isSameId(message.sender.id) \|\| this.#notConfirmedMessage(message)) return;
		this.#sendbox && console.log('transport on callback', channel, message)
		@@ -307,0 +308,0 @@ callback(ch, message.data);

New alerts