View Javadoc
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   * Force a shutdown of the system
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  }