Stop.java
package emissary.core.sentinel.protocols.actions;
import emissary.core.sentinel.Sentinel;
import emissary.server.EmissaryServer;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
/**
* Attempt a graceful shutdown of the system
*/
public class Stop extends Action {
@Override
public void trigger(Map<String, Sentinel.Tracker> trackers) {
logger.error("Sentinel detected unrecoverable agents, initiating graceful shutdown -- {}", format(trackers));
var unused = CompletableFuture.runAsync(EmissaryServer::stopServer);
}
}