Merge pull request #193 from xujihui1985/master

fix: emit the error instead of slient swallow it
SOHU-Co · Apr 8, 2015 · a5c04e7 · a5c04e7
2 parents 9cf6501 + 6415a4c
commit a5c04e7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/zookeeper.js b/lib/zookeeper.js
@@ -253,10 +253,12 @@ Zookeeper.prototype.listConsumers = function (groupId) {
             that.listConsumers(groupId);
         },
         function (error, children) {
-            if (error)
+            if (error) {
                 debug(error);
-            else
+                that.emit('error', error);
+            } else {
                 that.emit('consumersChanged');
+            }
         }
     );
 };