Stop.java

  1. package emissary.core.sentinel.protocols.actions;

  2. import emissary.core.sentinel.Sentinel;
  3. import emissary.server.EmissaryServer;

  4. import java.util.Map;
  5. import java.util.concurrent.CompletableFuture;

  6. /**
  7.  * Attempt a graceful shutdown of the system
  8.  */
  9. public class Stop extends Action {

  10.     @Override
  11.     public void trigger(Map<String, Sentinel.Tracker> trackers) {
  12.         logger.error("Sentinel detected unrecoverable agents, initiating graceful shutdown -- {}", format(trackers));
  13.         var unused = CompletableFuture.runAsync(EmissaryServer::stopServer);
  14.     }
  15. }