Attempt to fix issue sreeix#18

wankdanker · Sep 4, 2014 · ea483e1 · ea483e1
1 parent 041d992
commit ea483e1
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/lib/server.js b/lib/server.js
@@ -59,7 +59,21 @@ Server.prototype.sendCommand = function(command, id, cb){
       return cb(err);
     }
     logger.debug('sending command to redis '+ command);
-    conn.write(command);
+
+    try {
+        conn.write(command, function (err) {
+            if (err) {
+                logger.error(err);
+            }
+        });
+    }
+    catch (e) {
+        logger.error(e);
+        //TODO: in this case we should either  return that the command send failed
+        //or queue it until another redis server is available.
+
+    }
+
     return cb(null, conn);
   });
 };