Released December 30, 2021
Last updated
public class Main implements LivePlugin {
public void start(Live live) throws Exception {
...
HealthcheckMonitorService monitorService = Objects.requireNonNull(live.system().getPluginService(HealthcheckMonitorService.class));
monitorService.registerMonitor(live, new MyMonitor());
...
}
}public class MyMonitor implements HealthcheckMonitor {
private static final String QUERY = ""; // some query
private static final String EVENT_TYPE = ""; //some event type
private Live.Action queriesHandler;
@Override
public void start(@NotNull Live live, @NotNull HealthcheckConfig healthcheckConfig) throws Exception {
//start monitoring
String statsEmail = healthcheckConfig.getGeneralStatsRecipient();
final List<String> statsRecipients = Collections.singletonList(statsEmail);
QueryListener.Empty listener = new QueryListener.Empty() {
@Override
public void onEvent(QueryEvent events, boolean history) throws Exception {
if (history) return;
Map<String, Object> stats = HealthCheckUtils.loadBaseEvent(live, EVENT_TYPE, HealthCheckUtils::hostNameSupplier);
for (Map<String, Object> event : events) {
stats.put("key1", event.get("key1"));
}
String json = LiveJson.toJson(stats);
HealthCheckUtils.sendEmailWithAttachments(live, json, statsRecipients);
}
};
Query query = new Query(QUERY)
.follow(true)
.preloadWindow(true)
.description("My monitor query")
.listenWith(listener);
queriesHandler = live.queries().run(query);
}
@Override
public void stop(@NotNull Live live) throws Exception {
//stop monitoring
if (queriesHandler != null) {
queriesHandler.close();
}
}
}...
<dependencies>
...
<dependency>
<groupId>net.intelie.live</groupId>
<artifactId>plugin-healthcheck</artifactId>
<version>3.15.0</version>
<scope>provided</scope>
</dependency>
...
</dependencies>
...