From 121ea2f039307562565cd56ab11e0757cd72059d Mon Sep 17 00:00:00 2001 From: ascrutae Date: Fri, 29 Jan 2016 10:54:07 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=B1=BB=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ai/cloud/skywalking/alarm/AlarmProcessServer.java | 2 +- ...ectThread.java => NumberOfUsersChangeDetectionThread.java} | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) rename skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/{UserNumberInspectThread.java => NumberOfUsersChangeDetectionThread.java} (93%) diff --git a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/AlarmProcessServer.java b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/AlarmProcessServer.java index a15517300..e27312d31 100644 --- a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/AlarmProcessServer.java +++ b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/AlarmProcessServer.java @@ -38,7 +38,7 @@ public class AlarmProcessServer { processThreads.add(tmpThread); } logger.info("Successfully launched {} processing threads.", Config.Server.PROCESS_THREAD_SIZE); - new UserNumberInspectThread().start(); + new NumberOfUsersChangeDetectionThread().start(); logger.info("Successfully launched the thread that inspect the number of user"); logger.info("Alarm process server successfully started."); while (true) { diff --git a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserNumberInspectThread.java b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/NumberOfUsersChangeDetectionThread.java similarity index 93% rename from skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserNumberInspectThread.java rename to skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/NumberOfUsersChangeDetectionThread.java index 3a06aae4c..1d59698db 100644 --- a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserNumberInspectThread.java +++ b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/NumberOfUsersChangeDetectionThread.java @@ -11,13 +11,13 @@ import org.apache.logging.log4j.Logger; import java.sql.SQLException; import java.util.concurrent.TimeUnit; -public class UserNumberInspectThread extends Thread { +public class NumberOfUsersChangeDetectionThread extends Thread { private boolean isInspector = false; private InterProcessMutex inspectorLock = new InterProcessMutex(ZKUtil.getZkClient(), Config.ZKPath.INSPECTOR_LOCK_PATH); private String userIdsEncryptedStr; - private Logger logger = LogManager.getLogger(UserNumberInspectThread.class); + private Logger logger = LogManager.getLogger(NumberOfUsersChangeDetectionThread.class); public void run() { while (true) {