diff --git a/index.js b/index.js
index f3916f5..9eebd84 100644
--- a/index.js
+++ b/index.js
@@ -70,8 +70,8 @@ Adapter.prototype.connect = function(cb) {
 }
 
 Adapter.prototype.end = function(cb) {
-  this.pubClient.end();
-  this.subClient.end();
+  this.redisPubClient.end();
+  this.redisSubClient.end();
 }
 
 /**