Comparing version 0.0.1 to 0.0.2
@@ -23,5 +23,6 @@ "use strict"; | ||
var connect = (function connectWrapper() { | ||
var connectionPromise, connection; | ||
var connectionPromise, connection, isConnected = false; | ||
function ready() { | ||
isConnected = true; | ||
LOGGER.debug("connected"); | ||
@@ -40,2 +41,8 @@ connection.removeListener("error", connectionError); | ||
function checkConnected() { | ||
if (!isConnected) { | ||
connectionError(new Error("Connection closed prematurely, please check your credentials")); | ||
} | ||
} | ||
return function connect(url, opts) { | ||
@@ -47,2 +54,3 @@ if (!connectionPromise) { | ||
connection.once('error', connectionError); | ||
connection.once("close", checkConnected); | ||
} | ||
@@ -49,0 +57,0 @@ return connectionPromise; |
{ | ||
"name": "hare", | ||
"version": "0.0.1", | ||
"version": "0.0.2", | ||
"description": "Wrapper around amqp to make common patterns easier", | ||
@@ -17,3 +17,3 @@ "main": "index.js", | ||
"amqp": "~0.1.3", | ||
"comb": "~0.1.10" | ||
"comb": "~0.2.0" | ||
}, | ||
@@ -20,0 +20,0 @@ "devDependencies": { |
32029
690
+ Addedcomb@0.2.11(transitive)
- Removedcomb@0.1.91(transitive)
Updatedcomb@~0.2.0