@fonos/events
Advanced tools
Comparing version 0.0.86 to 0.0.87
"use strict"; | ||
var __awaiter = | ||
(this && this.__awaiter) || | ||
function (thisArg, _arguments, P, generator) { | ||
function adopt(value) { | ||
return value instanceof P | ||
? value | ||
: new P(function (resolve) { | ||
resolve(value); | ||
}); | ||
} | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { | ||
try { | ||
step(generator.next(value)); | ||
} catch (e) { | ||
reject(e); | ||
} | ||
} | ||
function rejected(value) { | ||
try { | ||
step(generator["throw"](value)); | ||
} catch (e) { | ||
reject(e); | ||
} | ||
} | ||
function step(result) { | ||
result.done | ||
? resolve(result.value) | ||
: adopt(result.value).then(fulfilled, rejected); | ||
} | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
var __importDefault = | ||
@@ -47,11 +14,9 @@ (this && this.__importDefault) || | ||
} | ||
sendToQ(payload) { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
logger_1.default.log( | ||
"debug", | ||
`events.EventsSender.sendToQ [sent message to q => ${this.q}]` | ||
); | ||
yield this.channelWrapper.sendToQueue(this.q, { | ||
data: payload | ||
}); | ||
async sendToQ(payload) { | ||
logger_1.default.log( | ||
"debug", | ||
`events.EventsSender.sendToQ [sent message to q => ${this.q}]` | ||
); | ||
await this.channelWrapper.sendToQueue(this.q, { | ||
data: payload | ||
}); | ||
@@ -58,0 +23,0 @@ } |
{ | ||
"name": "@fonos/events", | ||
"version": "0.0.86", | ||
"version": "0.0.87", | ||
"description": "Fonos events managment", | ||
@@ -32,3 +32,3 @@ "author": "Pedro Sanders <psanders@fonoster.com>", | ||
"dependencies": { | ||
"@fonos/logger": "^0.0.86", | ||
"@fonos/logger": "^0.0.87", | ||
"amqp-connection-manager": "^3.2.2", | ||
@@ -43,3 +43,3 @@ "amqplib": "^0.6.0" | ||
}, | ||
"gitHead": "1960653645524d4dc572f9aaf3d1d7eed79d5d38" | ||
"gitHead": "f432bd97cab50bfebfe2be9847cc5e2ff890c750" | ||
} |
6157
128
+ Added@fonos/logger@0.0.87(transitive)
- Removed@fonos/logger@0.0.86(transitive)
Updated@fonos/logger@^0.0.87