Comparing version 0.4.1 to 0.4.2
@@ -40,4 +40,6 @@ var debug = require('debug')('rascal:Subscription') | ||
getContent(message, config, function(err, content) { | ||
err ? session.emit('error', err) | ||
: session.emit('message', message, content, ackOrNack.bind(null, channel, message)) | ||
setImmediate(function() { | ||
err ? session.emit('error', err) | ||
: session.emit('message', message, content, ackOrNack.bind(null, channel, message)) | ||
}) | ||
}) | ||
@@ -44,0 +46,0 @@ }, config.options, function(err, response) { |
{ | ||
"name": "rascal", | ||
"version": "0.4.1", | ||
"version": "0.4.2", | ||
"description": "A friendly wrapper around amqplib with (mostly) safe defaults", | ||
@@ -5,0 +5,0 @@ "main": "index.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
161171
3657