public void exec(final ClusterState clusterState,
                     final int delay,
                     final boolean testActiveNodes) {
        securityContext.secure(() -> {
            try {
                // We sometimes want to wait a bit before we try and establish the
                // cluster state. This is often the case during startup when multiple
                // nodes start to ping each other which triggers an update, but we want
                // to give other nodes some time to start also.
                if (delay > 0) {
                    Thread.sleep(delay);
                }

                updateState(clusterState, testActiveNodes);
            } catch (final InterruptedException e) {
                LOGGER.debug(e.getMessage(), e);

                // Continue to interrupt this thread.
                Thread.currentThread().interrupt();
            }
        });
    }
Trigger a re-discover if the node saves
stroom-cluster/stroom-cluster-impl/src/main/java/stroom/cluster/impl/ClusterNodeManagerImpl.java