Improved logging.

Author: mcollina

lib/client.js

@@ -29,7 +29,7 @@ function Client(conn, server) {
  * @api private
  */
 Client.prototype._setup = function() {
-  var that = this, logger = this.logger, client = that.connection;
+  var that = this, client = that.connection;
 
   this._buildForward();
 
@@ -42,7 +42,7 @@ Client.prototype._setup = function() {
   });
 
   client.on("pingreq", function() {
-    logger.debug("pingreq");
+    that.logger.debug("pingreq");
     that.setUpTimer();
     that.connection.pingresp();
   });
@@ -59,10 +59,10 @@ Client.prototype._setup = function() {
   });
 
   client.on("unsubscribe", function(packet) {
-    logger.info({ packet: packet }, "unsubscribe received");
+    that.logger.info({ packet: packet }, "unsubscribe received");
     async.parallel(packet.unsubscriptions.map(that.unsubscribeMapTo.bind(that)), function(err) {
       if (err) {
-        logger.warn(err);
+        that.logger.warn(err);
         that.unsubAndClose();
         return;
       }
@@ -73,17 +73,17 @@ Client.prototype._setup = function() {
   });
 
   client.on("disconnect", function() {
-    logger.debug("disconnect requested");
+    that.logger.debug("disconnect requested");
     that.unsubAndClose();
   });
 
   client.on("error", function(err) {
-    logger.warn(err);
+    that.logger.warn(err);
     that.unsubAndClose();
   });
 
   client.on("close", function() {
-    logger.info("disconnected");
+    that.logger.info("disconnected");
     that._closed = true;
     that.onClose();
   });