small fix to make sure the connect was killed

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>net.limework.core</groupId>
     <artifactId>LimeworkSpigotCore</artifactId>
-    <version>1.0.2-SNAPSHOT</version>
+    <version>1.0.3-fix2-SNAPSHOT</version>
     <packaging>jar</packaging>
 	
     <build>

src/main/java/net/limework/core/LimeworkSpigotCore.java

@@ -19,6 +19,7 @@ public class LimeworkSpigotCore extends JavaPlugin {
     public void onEnable() {
         saveDefaultConfig();
         rm = new RedisManager(this);
+        getServer().getPluginCommand("reloadredis").setExecutor(rm);
         if (getServer().getPluginManager().getPlugin("Skript") != null) {
             new SkriptHook(this);
         } else {

src/main/java/net/limework/core/managers/RedisManager.java

@@ -3,10 +3,16 @@ package net.limework.core.managers;
 import net.limework.Data.Encryption;
 import net.limework.core.LimeworkSpigotCore;
 import net.limework.core.events.RedisMessageEvent;
+import net.md_5.bungee.api.chat.TextComponent;
 import org.bukkit.Bukkit;
 import org.bukkit.ChatColor;
+import org.bukkit.command.Command;
+import org.bukkit.command.CommandExecutor;
+import org.bukkit.command.CommandSender;
 import org.bukkit.configuration.Configuration;
+import org.bukkit.entity.Player;
 import org.cryptomator.siv.UnauthenticCiphertextException;
+import org.jetbrains.annotations.NotNull;
 import org.json.JSONObject;
 import redis.clients.jedis.BinaryJedis;
 import redis.clients.jedis.BinaryJedisPubSub;
@@ -19,13 +25,14 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.AtomicBoolean;
 
-public class RedisManager extends BinaryJedisPubSub implements Runnable{
+public class RedisManager extends BinaryJedisPubSub implements Runnable, CommandExecutor {
 
     private LimeworkSpigotCore plugin;
 
     private JedisPool jedisPool;
     private ExecutorService RedisService;
 
+    private AtomicBoolean isKilled = new AtomicBoolean();
 
 
     //sub
@@ -51,19 +58,23 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable{
                 config.getString("Redis.Password"),
                 config.getBoolean("Redis.useSSL"));
         RedisService = Executors.newFixedThreadPool(config.getInt("Redis.Threads"));
-        try{this.subscribeJedis = this.jedisPool.getResource(); }catch (Exception ignored){}
+        try {
+            this.subscribeJedis = this.jedisPool.getResource();
+        } catch (Exception ignored) {
+        }
         this.channels = config.getStringList("Channels");
         encryption = new Encryption(config);
 
     }
 
-    public void start(){
+    public void start() {
         this.RedisService.execute(this);
     }
 
     @Override
     public void run() {
         while (!isShuttingDown.get()) {
+            isKilled.set(false);
             try {
                 message("&e[Jedis] &cConnecting to redis...........");
                 if (!this.subscribeJedis.isConnected()) this.subscribeJedis = this.jedisPool.getResource();
@@ -92,7 +103,9 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable{
 
             } catch (Exception e) {
                 message("&e[Jedis] &cConnection to redis has failed! &ereconnecting...");
-                if (this.subscribeJedis != null){this.subscribeJedis.close();}
+                if (this.subscribeJedis != null) {
+                    this.subscribeJedis.close();
+                }
                 isRedisOnline.set(false);
             }
             try {
@@ -100,6 +113,7 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable{
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
+            if (isKilled.get()) break;
         }
     }
 
@@ -130,7 +144,7 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable{
 
     public void shutdown() {
         this.isShuttingDown.set(true);
-        if (this.subscribeJedis != null){
+        if (this.subscribeJedis != null) {
             this.unsubscribe();
             this.subscribeJedis.close();
         }
@@ -161,4 +175,24 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable{
     public Encryption getEncryption() {
         return encryption;
     }
+
+    @Override
+    public boolean onCommand(CommandSender sender, Command cmd, String lable, String[] args) {
+        if (sender instanceof Player) {
+            sender.sendMessage(TextComponent.fromLegacyText(ChatColor.translateAlternateColorCodes('&'
+                    , "&c&lYou can not execute this command!!!!!!")));
+            return true;
+        }
+        isKilled.set(true);
+        try {
+            if (this.subscribeJedis != null) {
+                this.unsubscribe();
+                this.subscribeJedis.close();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        start();
+        return false;
+    }
 }

src/main/resources/plugin.yml

@@ -7,5 +7,8 @@ softdepend:
   - Skript
 commands:
   control:
+    description: "server control"
+    permission: "admin.use"
+  reloadredis:
     description: "server control"
     permission: "admin.use"