diff --git a/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java b/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java index f7bfca9..1926f63 100644 --- a/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java +++ b/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java @@ -161,7 +161,7 @@ public class RedisBungee extends Plugin implements Listener { getProxy().getPluginManager().registerListener(this, this); api = new RedisBungeeAPI(this); psl = new PubSubListener(); - getProxy().getScheduler().runAsync(this, psl); + psl.start(); } } @@ -305,11 +305,15 @@ public class RedisBungee extends Plugin implements Listener { event.setResponse(reply); } - private class PubSubListener implements Runnable { + private class PubSubListener extends Thread { private Jedis rsc; private JedisPubSubHandler jpsh; + private PubSubListener() { + super("RedisBungee PubSub Listener"); + } + @Override public void run() { try {