added protection to kill current working sub

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>net.limework.core</groupId>
     <artifactId>LimeworkSpigotCore</artifactId>
-    <version>1.0.1-SNAPSHOT</version>
+    <version>1.0.3-fix1-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/DataSourcesManager.java

@@ -13,7 +13,7 @@ public class DataSourcesManager {
     public DataSourcesManager(LimeworkSpigotCore plugin) {
         Configuration config = plugin .getConfig();
         if (config.getBoolean("Mongodb.enabled")){
-            mongoClient = MongoClients.create();
+            mongoClient = MongoClients.create(config.getString("Mongodb.url"));
         }
     }
 

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,7 +25,7 @@ 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;
 
@@ -27,7 +33,6 @@ public class RedisManager extends BinaryJedisPubSub implements Runnable{
     private ExecutorService RedisService;
 
 
-
     //sub
     private BinaryJedis subscribeJedis;
     private List<String> channels;
@@ -51,7 +56,10 @@ 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);
 
@@ -92,7 +100,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 {
@@ -161,4 +171,23 @@ 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;
+        }
+        try {
+            if (this.subscribeJedis != null) {
+                this.unsubscribe();
+                this.subscribeJedis.close();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        start();
+        return false;
+    }
 }

src/main/resources/plugin.yml

@@ -9,3 +9,6 @@ commands:
   control:
     description: "server control"
     permission: "admin.use"
+  reloadredis:
+    description: "server control"
+    permission: "admin.use"