@ -56,7 +56,7 @@ public class AlertServer {
logger.info("alert server ready start ");
while (Stopper.isRunning()){
try {
Thread.sleep(Constants.ALERT_SCAN_INTERVEL);
Thread.sleep(Constants.ALERT_SCAN_INTERVAL);
} catch (InterruptedException e) {
logger.error(e.getMessage(),e);
Thread.currentThread().interrupt();
@ -133,7 +133,7 @@ public class Constants {
public static final String TH_END = "</th>";
public static final int ALERT_SCAN_INTERVEL = 5000;
public static final int ALERT_SCAN_INTERVAL = 5000;
public static final String MARKDOWN_QUOTE = ">";
@ -25,7 +25,7 @@ public class Stopper {
private static volatile AtomicBoolean signal = new AtomicBoolean(false);
public static final boolean isStoped(){
public static final boolean isStopped(){
return signal.get();
}
@ -98,7 +98,7 @@ public class ThreadUtilsTest {
public void testStopper() {
assertTrue(Stopper.isRunning());
Stopper.stop();
assertTrue(Stopper.isStoped());
assertTrue(Stopper.isStopped());
/**
@ -173,7 +173,7 @@ public class MasterServer implements IStoppable {
//execute only once
if(Stopper.isStoped()){
if(Stopper.isStopped()){
return;
@ -201,7 +201,7 @@ public class WorkerServer implements IStoppable {