Class LagDetector


public class LagDetector
extends java.lang.Object
A publication can succeed and complete before all nodes have applied the published state and acknowledged it; however we need every node eventually either to apply the published state (or a later state) or be removed from the cluster. This component achieves this by removing any lagging nodes from the cluster after a timeout.