vendease-common - npm Package Compare versions

		@@ -5,2 +5,3 @@ "use strict";
		const logger_1 = require("../../../util/logger");
		const notifications_1 = require("../../../notifications");
		class Listener {
		@@ -14,4 +15,4 @@ constructor(client) {
		this.consumMessage = (msg) => {
		console.log(this.onMessage);
		logger_1.logger.info(`Message received: ${this.subject} / ${this.queueGroupName}`);
		notifications_1.slackNotification.send(`Message received: ${this.subject} / ${this.queueGroupName}`, false);
		const parsedData = this.parseMessage(msg);
		@@ -18,0 +19,0 @@ logger_1.logger.info(`consuming message....`);

build/events/v1/base/publisher.js

		@@ -5,2 +5,3 @@ "use strict";
		const logger_1 = require("../../../util/logger");
		const notifications_1 = require("../../../notifications");
		class Publisher {
		@@ -11,10 +12,11 @@ constructor(client) {
		publish(data) {
		const self = this;
		logger_1.logger.info(`Publishing to ${self.subject}`);
		logger_1.logger.info(`Publishing to ${this.subject}`);
		return new Promise((resolve, reject) => {
		this.client.publish(self.subject, JSON.stringify(data), (err) => {
		this.client.publish(this.subject, JSON.stringify(data), (err) => {
		if (err) {
		notifications_1.slackNotification.send(err.message, true);
		return reject(err);
		}
		logger_1.logger.info(`Event published to subject [${self.subject}]`);
		logger_1.logger.info(`Event published to subject [${this.subject}]`);
		notifications_1.slackNotification.send(JSON.stringify(data), false);
		resolve();
		@@ -21,0 +23,0 @@ });

package.json

Fixed alerts