servicebus - npm Package Compare versions

Comparing version 0.0.8 to 0.0.9

bus/bus.js

@@ -145,9 +145,3 @@ var util = require('util'),
     };
-    var timeout = function() {
-      self.connection.removeListener('ready', republish);
-      process.nextTick(republish);
-    };
-    var timeoutId = setTimeout(timeout, 1000);
     self.connection.on('ready', function() {
-      clearTimeout(timeoutId);
       process.nextTick(republish);
@@ -170,2 +164,2 @@ });
   return bus;
-}
+}

bus/pubsubqueue.js

@@ -113,3 +113,3 @@ var events = require('events'),
       q.on('queueBindOk', function() {
-        self.log.debug('bound to ' + self.log.errorQueueName);  
+        self.log.debug('bound to ' + self.errorQueueName);  
       });
@@ -116,0 +116,0 @@ });

package.json

@@ -7,3 +7,3 @@ {
   "description": "Simple service bus for sending events between processes using amqp.",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "homepage": "https://github.com/mateodelnorte/servicebus",
@@ -10,0 +10,0 @@ "repository": {

No alert changes

Worsened metrics

Total package byte prevSize

27017

-0.78%

Lines of code

721

-0.69%

No dependency changes