rabbitmq-eventemitter - npm Package Compare versions

Comparing version 1.3.1 to 1.4.0

index.js

@@ -13,2 +13,4 @@ var util = require('util');
 
+var nextTick = process.nextTick;
+
 var Queue = function(url, options) {
@@ -26,2 +28,7 @@ if(!(this instanceof Queue)) return new Queue(url, options);
 
+	var onclose = function(err) {
+		if(err) onerror(err);
+		self.emit('close');
+	};
+
 	this._getConnection = thunky(function(callback) {
@@ -31,3 +38,9 @@ amqp.connect(url, options.connectOptions, function(err, connection) {
 
-			connection.on('error', onerror);
+			connection.on('error', function(err) {
+				nextTick(onerror, err);
+			});
+			connection.on('close', function(err) {
+				nextTick(onclose, err);
+			});
+
 			callback(null, connection);
@@ -138,3 +151,3 @@ });
 			// channel.consume eats uncaught exceptions
-			process.nextTick(function() {
+			nextTick(function() {
 				var data = JSON.parse(message.content.toString());
@@ -141,0 +154,0 @@ var onresponse = function(err) {

package.json

 {
   "name": "rabbitmq-eventemitter",
-  "version": "1.3.1",
+  "version": "1.4.0",
   "description": "Simplified rabbitmq events",
@@ -23,3 +23,3 @@ "main": "index.js",
     "after-all": "^2.0.2",
-    "amqplib": "^0.3.2",
+    "amqplib": "^0.5.0",
     "once": "^1.3.2",
@@ -26,0 +26,0 @@ "randomstring": "^1.0.7",

No alert changes

Improved metrics

Total package byte prevSize

9419

increased by5.22%

Number of package files

5

increased by25%

Lines of code

193

increased by10.92%

Dependency changes

• + Addedamqplib@0.5.6(transitive)

• + Addedbitsyntax@0.1.0(transitive)

• + Addedbluebird@3.7.2(transitive)

• + Addedbuffer-more-ints@1.0.0(transitive)

• + Addeddebug@2.6.9(transitive)

• + Addedms@2.0.0(transitive)

• + Addedquerystringify@2.2.0(transitive)

• + Addedrequires-port@1.0.0(transitive)

• + Addedsafe-buffer@5.1.2(transitive)

• + Addedurl-parse@1.4.7(transitive)

• - Removedamqplib@0.3.2(transitive)

• - Removedbitsyntax@0.0.4(transitive)

• - Removedbuffer-more-ints@0.0.2(transitive)

• - Removedsafe-buffer@5.2.1(transitive)

• - Removedwhen@3.6.4(transitive)

• Updatedamqplib@^0.5.0