rabbitmq-eventemitter - npm Package Compare versions

Comparing version 1.0.4 to 1.1.0

index.js

@@ -34,4 +34,6 @@ var util = require('util');
 
+	var getChannel = function(callback) {
+		var channelOptions = options.channelOptions || {};
+		var prefetch = channelOptions.prefetch;
 
-	var getChannel = function(callback) {
 		self._getConnection(function(err, connection) {
@@ -42,5 +44,15 @@ if(err) return callback(err);
 				if(err) return callback(err);
+				channel.on('error', onerror);
 
-				channel.on('error', onerror);
-				callback(null, channel);
+				if(prefetch) {
+					var onprefetch = afterAll(function(err) {
+						if(err) return callback(err);
+						callback(null, channel);
+					});
+
+					if(prefetch.global) channel.prefetch(prefetch.global, true, onprefetch());
+					if(prefetch.local) channel.prefetch(prefetch.local, false, onprefetch());
+				} else {
+					callback(null, channel);
+				}
 			});
@@ -47,0 +59,0 @@ });

package.json

 {
   "name": "rabbitmq-eventemitter",
-  "version": "1.0.4",
+  "version": "1.1.0",
   "description": "Simplified rabbitmq events",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

8302

increased by5.3%

Lines of code

159

increased by7.43%

No dependency changes