1 package emissary.core.sentinel.protocols.actions;
2
3 import emissary.core.sentinel.Sentinel;
4 import emissary.server.EmissaryServer;
5
6 import java.util.Map;
7 import java.util.concurrent.CompletableFuture;
8
9
10
11
12 public class Kill extends Action {
13
14 @Override
15 public void trigger(Map<String, Sentinel.Tracker> trackers) {
16 logger.error("Sentinel detected unrecoverable agents, initiating forceful shutdown -- {}", format(trackers));
17 var unused = CompletableFuture.runAsync(EmissaryServer::stopServerForce);
18 }
19 }