servicebus
Advanced tools
Comparing version 0.0.9 to 0.1.0
@@ -91,3 +91,3 @@ var events = require('events'), | ||
if ( ! this.exchange) { | ||
this.connection.on('readyToPublish', function () { | ||
this.connection.once('readyToPublish', function () { | ||
self.publish(event); | ||
@@ -154,2 +154,2 @@ }); | ||
module.exports = PubSubQueue; | ||
module.exports = PubSubQueue; |
@@ -7,3 +7,3 @@ { | ||
"description": "Simple service bus for sending events between processes using amqp.", | ||
"version": "0.0.9", | ||
"version": "0.1.0", | ||
"homepage": "https://github.com/mateodelnorte/servicebus", | ||
@@ -10,0 +10,0 @@ "repository": { |
27020
722