amqp-wrapper
Advanced tools
Comparing version 5.0.2 to 5.1.0
@@ -87,3 +87,3 @@ 'use strict'; | ||
*/ | ||
consume: function(handleMessage) { | ||
consume: function(handleMessage, options) { | ||
debug('consume()'); | ||
@@ -114,3 +114,3 @@ function callback(message) { | ||
channel.consume(config.queue.name, callback, {noAck: false}); | ||
channel.consume(config.queue.name, callback, options); | ||
} | ||
@@ -117,0 +117,0 @@ }; |
{ | ||
"name": "amqp-wrapper", | ||
"version": "5.0.2", | ||
"version": "5.1.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
17581