From 983d7567da51afe03dca7875069c6f7195e8ea98 Mon Sep 17 00:00:00 2001 From: Tux Date: Tue, 26 Nov 2013 14:51:52 -0500 Subject: [PATCH] Make the PubSub Listener its own thread --- .../imaginarycode/minecraft/redisbungee/RedisBungee.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) 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 {