socket.io-amqp0
Advanced tools
Comparing version 4.0.3 to 4.0.4
@@ -125,4 +125,5 @@ "use strict"; | ||
debug('Starting room listener for', room); | ||
const consumerTag = util_1.randomString(); | ||
this.consumeChannel.consume(queueName, async (msg) => { | ||
let consumerTag = util_1.randomString(); | ||
this.consumeChannel | ||
.consume(queueName, async (msg) => { | ||
if (!msg) | ||
@@ -136,3 +137,4 @@ return; | ||
consumerTag, | ||
}); | ||
}) | ||
.then((x) => (consumerTag = x.consumerTag)); | ||
return async () => { | ||
@@ -139,0 +141,0 @@ debug('Canceling room listener for', room); |
{ | ||
"name": "socket.io-amqp0", | ||
"version": "4.0.3", | ||
"version": "4.0.4", | ||
"description": "socket.io adapter for amqp 0.9.1+ (e.g. RabbitMQ)", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
Sorry, the diff of this file is not supported yet
No README
QualityPackage does not have a README. This may indicate a failed publish or a low quality package.
Found 1 instance in 1 package
41700
14
449
0
70