video-utils
Advanced tools
Comparing version 1.0.65 to 1.0.66
{ | ||
"name": "video-utils", | ||
"version": "1.0.65", | ||
"version": "1.0.66", | ||
"dependencies": { | ||
@@ -5,0 +5,0 @@ "amqp": "0.2.x", |
@@ -34,10 +34,13 @@ var | ||
if (_exchange && _exchange.state === 'open'){ | ||
_exchange.publish(generateRoutingKey(userId), data, { | ||
headers: { | ||
"event-type": channel | ||
} | ||
}, cb); | ||
if (_exchange) { | ||
if (_exchange.state === 'open') { | ||
_exchange.publish(generateRoutingKey(userId), data, { | ||
headers: { | ||
"event-type": channel | ||
} | ||
}, cb); | ||
} else { | ||
this._queue.push(arguments); | ||
} | ||
} else { | ||
this._queue.push(arguments); | ||
// нет обменника, создадим с типом direct и passive == false | ||
@@ -52,2 +55,3 @@ self._connection.exchange(exchange, { | ||
}); | ||
this._queue.push(arguments); | ||
} | ||
@@ -54,0 +58,0 @@ }; |
30290
13
650