kai1846456/RediSkript
1
0
Fork 0
forked from Limework/RediSkript
Code Pull Requests Activity

Fixed loop doesn;'t exist on server shutdown

Browse Source
This commit is contained in:
ham1255 2020-06-05 13:28:26 +04:00
parent 4f79fc29b7
commit fc72c698f4
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/net/limework/skLimework/Events/RedisSub.java
View File

@ -16,6 +16,7 @@ public class RedisSub extends JedisPubSub implements Runnable{
private AddonPlugin plugin;
private Jedis j;
private String[] channels;
private Boolean isShuttingDown = false;
public RedisSub(AddonPlugin plugin, Jedis j, List<String> channels) {
this.plugin = plugin;
@ -37,7 +38,7 @@ public class RedisSub extends JedisPubSub implements Runnable{
private void newJedis() {
//this.unsubscribe();
this.j.close();
while (true){
while (!isShuttingDown){
try {
plugin.getLogger().info("reconnecting to Redis!");
this.j = plugin.getJedisPool().getResource();
@ -48,6 +49,7 @@ public class RedisSub extends JedisPubSub implements Runnable{
try { Thread.sleep(4000);}catch (InterruptedException ignored){}
}
}
if (isShuttingDown) return;
plugin.getJedisExecutionService().execute(this);
}
@ -67,6 +69,7 @@ public class RedisSub extends JedisPubSub implements Runnable{
}
public void shutdown(){
isShuttingDown = true;
this.unsubscribe();
j.close();
}