From d5eb6ef5f3584234a409bc16d620dea9aa29860e Mon Sep 17 00:00:00 2001 From: Alex Date: Sun, 27 Mar 2022 20:58:33 +0200 Subject: [PATCH] redis test --- src/main/java/net/krakatoa/proxy/ProxySystem.java | 5 ++--- src/main/java/net/krakatoa/proxy/redis/RedisManager.java | 6 ++++++ 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/src/main/java/net/krakatoa/proxy/ProxySystem.java b/src/main/java/net/krakatoa/proxy/ProxySystem.java index a6c9d0b..68e6e22 100644 --- a/src/main/java/net/krakatoa/proxy/ProxySystem.java +++ b/src/main/java/net/krakatoa/proxy/ProxySystem.java @@ -86,9 +86,8 @@ public class ProxySystem extends Plugin { this.kraSocketClient.getSocketClient().getConnection().closeConnection(1, ""); this.mongoManager.getMongoClient().close(); - - //this.redisManager.getConnection().close(); - //this.redisManager.getClient().shutdown(); + + this.redisManager.close(); instance = null; } diff --git a/src/main/java/net/krakatoa/proxy/redis/RedisManager.java b/src/main/java/net/krakatoa/proxy/redis/RedisManager.java index e58b0d4..5927465 100644 --- a/src/main/java/net/krakatoa/proxy/redis/RedisManager.java +++ b/src/main/java/net/krakatoa/proxy/redis/RedisManager.java @@ -3,6 +3,7 @@ package net.krakatoa.proxy.redis; import lombok.Data; import org.redisson.Redisson; import org.redisson.api.RedissonClient; +import org.redisson.codec.JsonJacksonCodec; import org.redisson.config.Config; @Data @@ -20,6 +21,7 @@ public class RedisManager { public void connect() { this.config = new Config(); + this.config.setCodec(new JsonJacksonCodec()); this.config.useSingleServer().setAddress(this.connectionUri); this.redissonClient = Redisson.create(this.config); @@ -28,5 +30,9 @@ public class RedisManager { //this.commands = connection.sync(); //this.keyReactiveCommands = this.connection.reactive(); } + + public void close() { + this.redissonClient.shutdown(); + } } // RedisKeyReactiveCommands \ No newline at end of file