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);
    }
}