From 4359b251b90e75cf2bbdc1719864b0dc1ffd895f Mon Sep 17 00:00:00 2001 From: Tux Date: Thu, 31 Oct 2013 19:07:37 -0400 Subject: [PATCH] Fix count updates... --- .../minecraft/redisbungee/RedisBungee.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java b/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java index 575f353..c9d5079 100644 --- a/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java +++ b/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java @@ -59,7 +59,6 @@ public class RedisBungee extends Plugin implements Listener { int c = 0; try { c = plugin.getProxy().getOnlineCount(); - rsc.set("server:" + plugin.getServerId() + ":playerCount", String.valueOf(c)); for (String i : plugin.getServers()) { if (i.equals(plugin.getServerId())) continue; if (rsc.exists("server:" + i + ":playerCount")) @@ -167,6 +166,17 @@ public class RedisBungee extends Plugin implements Listener { } finally { pool.returnResource(tmpRsc); } + getProxy().getScheduler().schedule(this, new Runnable() { + @Override + public void run() { + Jedis rsc = pool.getResource(); + try { + rsc.set("server:" + plugin.getServerId() + ":playerCount", String.valueOf(getProxy().getOnlineCount())); + } finally { + pool.returnResource(rsc); + } + } + }, 1, 3, TimeUnit.SECONDS); getProxy().getPluginManager().registerCommand(this, new Command("glist", "bungeecord.command.glist", "redisbungee") { @Override public void execute(CommandSender sender, String[] args) {