diff --git a/src/main/java/net/limework/core/managers/RedisManager.java b/src/main/java/net/limework/core/managers/RedisManager.java index 3eebfa1..67b7257 100644 --- a/src/main/java/net/limework/core/managers/RedisManager.java +++ b/src/main/java/net/limework/core/managers/RedisManager.java @@ -60,9 +60,6 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable { } public void start() { - if (isShuttingDown.get()) { - isShuttingDown.set(false); - } this.RedisService.execute(this); } @@ -151,10 +148,9 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable { this.RedisService.shutdown(); } - public void reload() { - shutdown(); plugin.reloadConfig(); + subscribeJedis.close(); Configuration config = this.plugin.getConfig(); JedisPoolConfig JConfig = new JedisPoolConfig(); JConfig.setMaxTotal(config.getInt("Redis.MaxConnections")); @@ -167,7 +163,7 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable { config.getInt("Redis.TimeOut"), config.getString("Redis.Password"), config.getBoolean("Redis.useSSL")); - RedisService.shutdown(); + RedisService.shutdownNow(); RedisService = Executors.newFixedThreadPool(config.getInt("Redis.Threads")); try { this.subscribeJedis = this.jedisPool.getResource(); @@ -175,7 +171,6 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable { } this.channels = config.getStringList("Channels"); encryption = new Encryption(config); - start(); } public JedisPool getJedisPool() {