kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改类名

This commit is contained in:
ascrutae 2016-01-29 10:54:07 +08:00
parent 55c2d84bef
commit 121ea2f039
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/AlarmProcessServer.java
View File

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

4
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserNumberInspectThread.java → skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/NumberOfUsersChangeDetectionThread.java
View File

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