diff --git a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
index 710e3ab..5f503d1 100644
--- a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
+++ b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
@@ -12,9 +12,8 @@ public class PlayerDisconnectListener implements Listener {
   public void onDisconnect(PlayerDisconnectEvent event) {
     ProxiedPlayer proxiedPlayer = event.getPlayer();
 
-    ProxySystem.getInstance().getRedisManager().getCommands()
-        .getdel("player:" + proxiedPlayer.getUniqueId().toString());
-
+    ProxySystem.getInstance().getRedisManager().getKeyReactiveCommands()
+        .del("player:" + proxiedPlayer.getUniqueId().toString());
     //String uuid = ProxySystem.getInstance().getFormatter()
     //  .formatUuid(proxiedPlayer.getUniqueId().toString());
 
diff --git a/src/main/java/net/krakatoa/proxy/redis/RedisManager.java b/src/main/java/net/krakatoa/proxy/redis/RedisManager.java
index 84c217d..7281d5c 100644
--- a/src/main/java/net/krakatoa/proxy/redis/RedisManager.java
+++ b/src/main/java/net/krakatoa/proxy/redis/RedisManager.java
@@ -20,7 +20,7 @@ public class RedisManager {
     this.client = RedisClient.create(this.getConnectionUri());
     this.connection = client.connect();
     this.commands = connection.sync();
-    this.keyReactiveCommands = client.connect().reactive();
+    this.keyReactiveCommands = this.getConnection().reactive();
 
     this.getKeyReactiveCommands().del("player");
   }