com.hazelcast.spi.hotrestart.cluster

Class ClusterHotRestartEventListener

java.lang.Object

com.hazelcast.spi.hotrestart.cluster.ClusterHotRestartEventListener

All Implemented Interfaces:

EventListener

@PrivateApi
public abstract class ClusterHotRestartEventListener
extends Object
implements EventListener

This is a sync listener. When a node calls one of the methods below during Hot Restart, it will block until the method returns.

Constructor Summary

Constructors

Constructor and Description
ClusterHotRestartEventListener()

Method Summary

Modifier and Type	Method and Description
void	afterExpectedMembersJoin(Collection<? extends com.hazelcast.core.Member> members) Called on all nodes after all expected members join to the cluster.
void	beforeAllMembersJoin(Collection<? extends com.hazelcast.core.Member> currentMembers) Called while waiting for all members to join.
void	onDataLoadStart(com.hazelcast.core.Member member) Called when data load is started.
void	onHotRestartDataLoadComplete(HotRestartClusterStartStatus result, Set<String> excludedMemberUuids) Called on all nodes after the final cluster start decision is made.
void	onHotRestartDataLoadResult(com.hazelcast.core.Member sender, boolean success) Called on master when it receives a Hot Restart data load result from a node.
void	onPartitionTableValidationResult(com.hazelcast.core.Member sender, boolean success) Called after master receives a partition table from a member and validates it.
void	onPrepareComplete(Collection<? extends com.hazelcast.core.Member> members, com.hazelcast.internal.partition.PartitionTableView partitionTable, boolean startWithHotRestart) Called after a node completes the preparation by reading member list and partition table from disk
void	onSingleMemberCluster() Called when a persisted member list contains only a single member.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterHotRestartEventListener

public ClusterHotRestartEventListener()

Method Detail

onPrepareComplete

public void onPrepareComplete(Collection<? extends com.hazelcast.core.Member> members,
                              com.hazelcast.internal.partition.PartitionTableView partitionTable,
                              boolean startWithHotRestart)

Called after a node completes the preparation by reading member list and partition table from disk

Parameters:

members - member list which is read from the disk

partitionTable - partition table which is read from disk

startWithHotRestart - if false, node will start without hot restart

onSingleMemberCluster

public void onSingleMemberCluster()

Called when a persisted member list contains only a single member.

beforeAllMembersJoin

public void beforeAllMembersJoin(Collection<? extends com.hazelcast.core.Member> currentMembers)

Called while waiting for all members to join.

Parameters:

currentMembers - currently joined members

afterExpectedMembersJoin

public void afterExpectedMembersJoin(Collection<? extends com.hazelcast.core.Member> members)

Called on all nodes after all expected members join to the cluster.

Parameters:

members - expected member list

onPartitionTableValidationResult

public void onPartitionTableValidationResult(com.hazelcast.core.Member sender,
                                             boolean success)

Called after master receives a partition table from a member and validates it.

Parameters:

sender - member that has sent the partition table

success - result of the validation

onDataLoadStart

public void onDataLoadStart(com.hazelcast.core.Member member)

Called when data load is started.

Parameters:

member - member that starts to load its own data

onHotRestartDataLoadResult

public void onHotRestartDataLoadResult(com.hazelcast.core.Member sender,
                                       boolean success)

Called on master when it receives a Hot Restart data load result from a node.

Parameters:

sender - member that sends its hot-restart data load result

success - result of the hot restart data load attempt of the node

onHotRestartDataLoadComplete

public void onHotRestartDataLoadComplete(HotRestartClusterStartStatus result,
                                         Set<String> excludedMemberUuids)

Called on all nodes after the final cluster start decision is made.

Parameters:

result - result of the cluster wide load operation