@fonos/events
Advanced tools
Comparing version 0.0.39 to 0.0.40
import RabbitQConnector from './rabbitq_connector'; | ||
export default class EventsSender extends RabbitQConnector { | ||
constructor(address: string[], q: string); | ||
sendToQ(event: string, payload: any): Promise<void>; | ||
sendToQ(payload: any): Promise<void>; | ||
} |
@@ -21,7 +21,6 @@ "use strict"; | ||
} | ||
sendToQ(event, payload) { | ||
sendToQ(payload) { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
logger_1.default.log('debug', `events.EventsSender.sendToQ [sent event to q => ${this.q}, event: ${event}]`); | ||
logger_1.default.log('debug', `events.EventsSender.sendToQ [sent message to q => ${this.q}]`); | ||
yield this.channelWrapper.sendToQueue(this.q, { | ||
name: event, | ||
data: payload | ||
@@ -28,0 +27,0 @@ }); |
@@ -18,5 +18,5 @@ "use strict"; | ||
json: true, | ||
setup: (chanell) => { | ||
setup: (channel) => { | ||
logger_1.default.log('info', `events.RabbitQConnector.connect [setting up q => ${this.q}, durable => false]`); | ||
return chanell.assertQueue(this.q, { durable: false }); | ||
return channel.assertQueue(this.q, { durable: false }); | ||
} | ||
@@ -23,0 +23,0 @@ }); |
{ | ||
"name": "@fonos/events", | ||
"version": "0.0.39", | ||
"version": "0.0.40", | ||
"description": "Fonos events managment", | ||
@@ -33,3 +33,3 @@ "author": "Pedro Sanders <psanders@fonoster.com>", | ||
"dependencies": { | ||
"@fonos/logger": "^0.0.39", | ||
"@fonos/logger": "^0.0.40", | ||
"amqp-connection-manager": "^3.2.0", | ||
@@ -43,3 +43,3 @@ "amqplib": "^0.6.0" | ||
}, | ||
"gitHead": "bd1f1fe1ea8c3b82fe2a96840f1d876eb90739eb" | ||
"gitHead": "26f8d2cfad3c2cf383bfa4c7d42e0abb77ab8d51" | ||
} |
6976
111
+ Added@fonos/logger@0.0.40(transitive)
- Removed@fonos/logger@0.0.39(transitive)
Updated@fonos/logger@^0.0.40