|
@@ -41,15 +41,17 @@ public class Watcher {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public void check() {
|
|
public void check() {
|
|
|
- Instant now = Instant.now();
|
|
|
|
|
|
|
|
|
|
- List<SimpleReport> reports = dataProvider.getLastRecords().parallelStream()
|
|
|
|
|
|
|
+ List<Record> records = dataProvider.getLastRecords();
|
|
|
|
|
+
|
|
|
|
|
+ Instant now = Instant.now();
|
|
|
|
|
+ List<SimpleReport> reports = records.parallelStream()
|
|
|
.map(r -> Tuple.of(r, config.getInterval(r)))
|
|
.map(r -> Tuple.of(r, config.getInterval(r)))
|
|
|
.filter(t -> t.getItem2().isPresent())
|
|
.filter(t -> t.getItem2().isPresent())
|
|
|
.map(t -> new SimpleReport(t.getItem1(), t.getItem1().isValid(t.getItem2().get(), now) ? OK : FAIL))
|
|
.map(t -> new SimpleReport(t.getItem1(), t.getItem1().isValid(t.getItem2().get(), now) ? OK : FAIL))
|
|
|
.collect(Collectors.toList());
|
|
.collect(Collectors.toList());
|
|
|
|
|
|
|
|
- messageBroker.send(new Report(ofInstant(now, UTC), reports), status -> {
|
|
|
|
|
|
|
+ messageBroker.send(new Report(ofInstant(now, ZoneId.systemDefault()), reports), status -> {
|
|
|
String brokerType = messageBroker.getType().name().toLowerCase();
|
|
String brokerType = messageBroker.getType().name().toLowerCase();
|
|
|
if (status.isSuccess()) {
|
|
if (status.isSuccess()) {
|
|
|
logger.info("The report at '{}' was send via '{}' broker successfully.",
|
|
logger.info("The report at '{}' was send via '{}' broker successfully.",
|