|
|
@@ -11,7 +11,6 @@ import org.apache.logging.log4j.Logger;
|
|
|
|
|
|
import java.io.IOException;
|
|
|
import java.time.LocalDateTime;
|
|
|
-import java.time.LocalTime;
|
|
|
|
|
|
public class Application extends Thread {
|
|
|
|
|
|
@@ -56,14 +55,18 @@ public class Application extends Thread {
|
|
|
MessageBroker messageBroker = MessageBroker.create(config.getMessageBrokerConfig());
|
|
|
Watcher watcher = Watcher.create(config.getWatchingObjectsConfig(), dataProvider, messageBroker);
|
|
|
|
|
|
- int period = config.getWatchingObjectsConfig().getMinInterval();
|
|
|
- LocalDateTime startAtTime = DateTrunc.trunc(LocalDateTime.now(), period).plusSeconds(period);
|
|
|
+ if (params.isExecuteImmediately()) {
|
|
|
+ watcher.check();
|
|
|
+ } else {
|
|
|
+ int period = config.getWatchingObjectsConfig().getMinInterval();
|
|
|
+ LocalDateTime startAtTime = DateTrunc.trunc(LocalDateTime.now(), period).plusSeconds(period);
|
|
|
|
|
|
- Scheduler scheduler = Scheduler.createBuilder()
|
|
|
+ Scheduler scheduler = Scheduler.createBuilder()
|
|
|
.addTask(watcher::check, period, startAtTime)
|
|
|
// .addTask(watcher::check, period)
|
|
|
- .build();
|
|
|
+ .build();
|
|
|
|
|
|
- scheduler.start();
|
|
|
+ scheduler.start();
|
|
|
+ }
|
|
|
}
|
|
|
}
|