Package org.apache.ignite.internal.managers.discovery

Class DiscoveryMessageResultsCollector<M,​R>

  • public abstract class DiscoveryMessageResultsCollector<M,​R>
extends Object

    • Constructor Detail

      • DiscoveryMessageResultsCollector

        protected DiscoveryMessageResultsCollector​(GridKernalContext ctx)
        Parameters:
        ctx - Context.

    • Method Detail

      • onResultsCollected

        protected abstract void onResultsCollected​(R r)
        Parameters:
        r - Result.

      • waitForNode

        protected abstract boolean waitForNode​(DiscoCache discoCache,
                                       ClusterNode node)
        Parameters:
        discoCache - Discovery state when discovery message was received.
        node - Node.
        Returns:
        True if need wait for result from given node.

      • init

        public final void init​(DiscoCache discoCache)
        Parameters:
        discoCache - Discovery state.

      • onMessage

        public final void onMessage​(UUID nodeId,
                            M msg)
        Parameters:
        nodeId - Node ID.
        msg - Message.

      • onNodeFail

        public final void onNodeFail​(UUID nodeId)
        Parameters:
        nodeId - Failed node ID.