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) {