servicebus
Advanced tools
Comparing version 0.2.0 to 0.2.1
@@ -137,3 +137,3 @@ var amqp = require('amqp'), | ||
self.initialized = true; | ||
self._publish(queueName, message); | ||
self.publish(queueName, message); | ||
}; | ||
@@ -140,0 +140,0 @@ self.connection.on('ready', function() { |
@@ -9,3 +9,3 @@ { | ||
"description": "Simple service bus for sending events between processes using amqp.", | ||
"version": "0.2.0", | ||
"version": "0.2.1", | ||
"homepage": "https://github.com/mateodelnorte/servicebus", | ||
@@ -12,0 +12,0 @@ "repository": { |
@@ -34,6 +34,6 @@ # servicebus | ||
bus.listen('my.event', { ack: true }, function (event, handle) { | ||
handle.acknowledge(); // acknowledge a message | ||
handle.ack(); // short hand is also available | ||
handle.reject(); // reject a message | ||
bus.listen('my.event', { ack: true }, function (event) { | ||
event.handle.acknowledge(); // acknowledge a message | ||
event.handle.ack(); // short hand is also available | ||
event.handle.reject(); // reject a message | ||
}); | ||
@@ -138,2 +138,2 @@ | ||
Retry provides ability to specify a max number of times an erroring message will be retried before being placed on an error queue. The retry middleware requires the correlate middleware. | ||
Retry provides ability to specify a max number of times an erroring message will be retried before being placed on an error queue. The retry middleware requires the correlate middleware. |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
33324
138
1