Merge pull request #7 from Mindflash/heartbeat

feat(heartbeat): added a heartbeat parameter to setup

index.js

@@ -8,11 +8,13 @@ var fs = require('fs');
 exports.log = console;
 
 var conns = [];
-exports.connect = function (url, name, callback) {
-	var conn = conns[url] = (conns[url] || amqp.createConnection({url: url}));
+
+exports.connectEx = function (options, callback) {
+	options = options || {};
+	var conn = conns[options.url] = (conns[options.url] || amqp.createConnection({url: options.url, heartbeat: options.heartbeat}));
 
 	if (conn.isReady)
-		connected(conn, name, callback);
+		connected(conn, options.name, callback);
 	else {
 		conn.addListener('ready', readyListener);
 		conn.addListener('error', function (err) {
@@ -22,15 +24,26 @@ exports.connect = function (url, name, callback) {
 			// We should probably rewrite this and make it an eventEmitter.
 			throw err;
 		});
+		conn.addListener('heartbeat', function () {
+			exports.log.debug('amqp heartbeat');
+		});
 	}
 
 	function readyListener() {
 		conn.removeListener('ready', readyListener);
 		conn.isReady = true;
-		connected(conn, name, callback);
+		connected(conn, options.name, callback);
 	}
 };
 
+ // backward compat connect method
+exports.connect = function (url, name, callback) {
+	return exports.connectEx({
+		url,
+		name
+	}, callback);
+};
+
 exports.close = function (url) {
 	if(!conns[url]) return;
 	conns[url].end();

package.json

@@ -1,6 +1,6 @@
 {
 	"name":"amqputil",
-	"version":"0.0.25",
+	"version":"0.0.26",
 	"description":"A thin wrapper around the amqp node module",
 	"main":"index.js",
 	"dependencies":{