amqp-as-promised
Advanced tools
Comparing version 0.4.0 to 0.4.1
@@ -73,3 +73,3 @@ // Generated by CoffeeScript 1.7.1 | ||
if (h) { | ||
opts.headers = h; | ||
popts.headers = h; | ||
} | ||
@@ -76,0 +76,0 @@ prev = (_ref4 = progress[progress.length - 1]) != null ? _ref4 : Q(); |
@@ -48,5 +48,3 @@ // Generated by CoffeeScript 1.7.1 | ||
return q.subscribe(function(msg, headers, deliveryInfo) { | ||
if (deliveryInfo != null) { | ||
return _this.resolveResponse(deliveryInfo.correlationId, msg, headers); | ||
} | ||
return _this.resolveResponse(deliveryInfo != null ? deliveryInfo.correlationId : void 0, msg, headers); | ||
}); | ||
@@ -73,3 +71,3 @@ }; | ||
var ct, p, prgsSeq, response, _ref1, _ref2; | ||
_ref1 = corrId.split('#x-progress:'), corrId = _ref1[0], prgsSeq = _ref1[1]; | ||
_ref1 = (corrId != null ? corrId : '').split('#x-progress:'), corrId = _ref1[0], prgsSeq = _ref1[1]; | ||
if (response = this.responses.get(corrId)) { | ||
@@ -76,0 +74,0 @@ _ref2 = decompress(msg, headers), ct = _ref2[0], p = _ref2[1]; |
{ | ||
"name": "amqp-as-promised", | ||
"description": "A promise-based AMQP API build on node-amqp", | ||
"version": "0.4.0", | ||
"version": "0.4.1", | ||
"repository": { | ||
@@ -6,0 +6,0 @@ "type": "git", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
85665
739