amqp-wrapper
Advanced tools
Comparing version 5.4.0 to 5.5.0
10
amqp.js
@@ -14,3 +14,3 @@ 'use strict'; | ||
var channel; | ||
var connection, channel; | ||
@@ -32,2 +32,3 @@ var prefetch = config.prefetch || 10; | ||
} | ||
connection = conn; | ||
@@ -62,2 +63,9 @@ conn.createConfirmChannel(assertExchange); | ||
close: function(cb) { | ||
if (connection) { | ||
return connection.close(cb); | ||
} | ||
cb(); | ||
}, | ||
/** | ||
@@ -64,0 +72,0 @@ * Publish a message using the specified routing key. |
{ | ||
"name": "amqp-wrapper", | ||
"version": "5.4.0", | ||
"version": "5.5.0", | ||
"description": "A wrapper around https://github.com/squaremo/amqp.node to make consuming and publishing dead easy.", | ||
@@ -5,0 +5,0 @@ "main": "amqp.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
19960
436