From 6a6b0ceb32a541ed9ac885cc8592a79c47d9fd38 Mon Sep 17 00:00:00 2001 From: Alex Date: Sun, 20 Mar 2022 21:08:42 +0100 Subject: [PATCH] implement Redis --- .../net/krakatoa/proxy/listener/PlayerDisconnectListener.java | 3 +++ src/main/java/net/krakatoa/proxy/redis/RedisManager.java | 4 +--- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java index 5f503d1..47ac99c 100644 --- a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java +++ b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java @@ -14,6 +14,9 @@ public class PlayerDisconnectListener implements Listener { ProxySystem.getInstance().getRedisManager().getKeyReactiveCommands() .del("player:" + proxiedPlayer.getUniqueId().toString()); + + ProxySystem.getInstance().getLogger().info("player disconnected: " + proxiedPlayer.getName()); + //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 7281d5c..b0ee049 100644 --- a/src/main/java/net/krakatoa/proxy/redis/RedisManager.java +++ b/src/main/java/net/krakatoa/proxy/redis/RedisManager.java @@ -20,9 +20,7 @@ public class RedisManager { this.client = RedisClient.create(this.getConnectionUri()); this.connection = client.connect(); this.commands = connection.sync(); - this.keyReactiveCommands = this.getConnection().reactive(); - - this.getKeyReactiveCommands().del("player"); + this.keyReactiveCommands = this.connection.reactive(); } } // RedisKeyReactiveCommands \ No newline at end of file