fix bug

NetEase · Jun 13, 2017 · 6292f9a · 6292f9a
1 parent 1eb91c8
commit 6292f9a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/monitors/redismonitor.js b/lib/monitors/redismonitor.js
@@ -183,14 +183,14 @@ var getMaster = function(self, redisNodes) {
               ping(self, client, redis);
             }, constants.TIME.DEFAULT_REDIS_PING);
           } else {
-            client.disconnect();
+            client.end();
             client = null;
           }
         });
       });
       client.on('error', function() {
         logger.error('[redisMonitor] monitor redis connect error');
-        client.disconnect();
+        client.end();
         client = null;
       });
     })(i);
@@ -203,7 +203,7 @@ var ping = function(self, client, rds) {
     clearInterval(self.pingtimer);
     if(self.pingtimer) {
       logger.info('[redisMonitor] clear pingtimer timeout');
-      client.disconnect();
+      client.end();
       client = null;
       self.pingtimer = null;
       rds.disconnect();