DiscoveryMessageResultsCollector (Ignite 2.8.0)

java.lang.Object
- org.apache.ignite.internal.managers.discovery.DiscoveryMessageResultsCollector<M,R>

public abstract class DiscoveryMessageResultsCollector<M,R>
extends Object

Nested Classes
Modifier and Type	Class and Description
`protected static class`	`DiscoveryMessageResultsCollector.NodeMessage<M>`

Fields
Modifier and Type	Field and Description
`protected GridKernalContext`	`ctx`
`protected DiscoCache`	`discoCache`

Constructors
Modifier	Constructor and Description
`protected`	`DiscoveryMessageResultsCollector(GridKernalContext ctx)`

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`protected abstract R`	`createResult(Map<UUID,DiscoveryMessageResultsCollector.NodeMessage<M>> rcvd)`
`void`	`init(DiscoCache discoCache)`
`void`	`onMessage(UUID nodeId, M msg)`
`void`	`onNodeFail(UUID nodeId)`
`protected abstract void`	`onResultsCollected(R r)`
`String`	`toString()`
`protected abstract boolean`	`waitForNode(DiscoCache discoCache, ClusterNode node)`

protected abstract R createResult(Map<UUID,DiscoveryMessageResultsCollector.NodeMessage<M>> rcvd)

protected abstract void onResultsCollected(R r)

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.

public final void init(DiscoCache discoCache)

public final void onMessage(UUID nodeId,
                            M msg)

public final void onNodeFail(UUID nodeId)

Class DiscoveryMessageResultsCollector<M,R>