exp-amqp-connection
Advanced tools
Comparing version
@@ -115,3 +115,3 @@ "use strict"; | ||
onExclusiveCallback(); | ||
logger.info("Exclusively subscribing to '" + queueName + "'. Other Ursula instances have to wait.", id); | ||
logger.info("Exclusively subscribing to '" + queueName + "'. Other instances will have to wait.", id); | ||
}); | ||
@@ -131,5 +131,3 @@ }); | ||
queue.bind(behaviour.exchange, routingKey); | ||
queue.subscribe(subscribeOptions, function (message) { | ||
return handler(message); | ||
}); | ||
queue.subscribe(subscribeOptions, handler); | ||
}); | ||
@@ -162,3 +160,3 @@ } | ||
} | ||
return api; | ||
@@ -165,0 +163,0 @@ } |
@@ -9,3 +9,3 @@ { | ||
], | ||
"version": "1.2.0", | ||
"version": "1.2.2", | ||
"scripts": { | ||
@@ -12,0 +12,0 @@ "test": "NODE_ENV=test mocha -t 5000 && jshint ." |
15899
-0.36%337
-0.59%