From 5215c2c11cdfcaea87d948878dec288df01c0be5 Mon Sep 17 00:00:00 2001 From: Dark Arc Date: Fri, 18 Jan 2013 16:31:25 -0500 Subject: [PATCH] Allow the queue size warning to be configurable --- src/main/java/de/diddiz/LogBlock/Consumer.java | 4 +++- src/main/java/de/diddiz/LogBlock/config/Config.java | 3 +++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/src/main/java/de/diddiz/LogBlock/Consumer.java b/src/main/java/de/diddiz/LogBlock/Consumer.java index c7c3695..2cb2d4e 100644 --- a/src/main/java/de/diddiz/LogBlock/Consumer.java +++ b/src/main/java/de/diddiz/LogBlock/Consumer.java @@ -260,8 +260,10 @@ public class Consumer extends TimerTask return; final Connection conn = logblock.getConnection(); Statement state = null; - if (getQueueSize() > 1000) + if (Config.queueWarningSize > 0 && queue.size() >= Config.queueWarningSize) { getLogger().info("[Consumer] Queue overloaded. Size: " + getQueueSize()); + } + try { if (conn == null) return; diff --git a/src/main/java/de/diddiz/LogBlock/config/Config.java b/src/main/java/de/diddiz/LogBlock/config/Config.java index d991f9b..e7898c2 100644 --- a/src/main/java/de/diddiz/LogBlock/config/Config.java +++ b/src/main/java/de/diddiz/LogBlock/config/Config.java @@ -26,6 +26,7 @@ public class Config public static int delayBetweenRuns, forceToProcessAtLeast, timePerRun; public static boolean fireCustomEvents; public static boolean useBukkitScheduler; + public static int queueWarningSize; public static boolean enableAutoClearLog; public static List autoClearLog; public static int autoClearLogDelay; @@ -73,6 +74,7 @@ public class Config def.put("consumer.timePerRun", 1000); def.put("consumer.fireCustomEvents", false); def.put("consumer.useBukkitScheduler", true); + def.put("consumer.queueWarningSize", 1000); def.put("clearlog.dumpDeletedLog", false); def.put("clearlog.enableAutoClearLog", false); def.put("clearlog.auto", Arrays.asList("world \"world\" before 365 days all", "world \"world\" player lavaflow waterflow leavesdecay before 7 days all", "world world_nether before 365 days all", "world world_nether player lavaflow before 7 days all")); @@ -133,6 +135,7 @@ public class Config timePerRun = config.getInt("consumer.timePerRun", 1000); fireCustomEvents = config.getBoolean("consumer.fireCustomEvents", false); useBukkitScheduler = config.getBoolean("consumer.useBukkitScheduler", true); + queueWarningSize = config.getInt("consumer.queueWarningSize", 1000); enableAutoClearLog = config.getBoolean("clearlog.enableAutoClearLog"); autoClearLog = config.getStringList("clearlog.auto"); dumpDeletedLog = config.getBoolean("clearlog.dumpDeletedLog", false);