com.gigaspaces.internal.server.space.replication

Class ReplicationNodeStateListener

java.lang.Object

com.gigaspaces.internal.cluster.node.AbstractReplicationNodeStateListener

com.gigaspaces.internal.server.space.replication.ReplicationNodeStateListener

All Implemented Interfaces:

IReplicationSourceGroupStateListener, IReplicationTargetGroupStateListener, IReplicationNodeStateListener

public class ReplicationNodeStateListener
extends AbstractReplicationNodeStateListener

Since:

10.0

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor and Description
ReplicationNodeStateListener(SpaceEngine spaceEngine)

Method Summary

Modifier and Type	Method and Description
void	onNewReplicaRequest(String groupName, String memberName, boolean isSynchronizeRequest) Called when new replica request is received, for custom validation
void	onSourceBrokenReplicationTopology(String groupName, String channelTargetMemberName, BrokenReplicationTopologyException error)
void	onSourceChannelActivated(String groupName, String memberName)
void	onTargetChannelBacklogDropped(String groupName, String channelSourceLookupName, IBacklogMemberState memberState) Called when a target channel received a notice that its backlog was dropped at the source
void	onTargetChannelCreationValidation(String groupName, String sourceMemberName, Object sourceUniqueId) Called when a new channel is being established, just before the channel is created to allow custom validation logic.
boolean	onTargetChannelOutOfSync(String groupName, String channelSourceLookupName, IncomingReplicationOutOfSyncException outOfSyncReason) Called when a target channel failed handshake due to becoming out of sync

Methods inherited from class com.gigaspaces.internal.cluster.node.AbstractReplicationNodeStateListener

onReplicationNodeModeChange, onTargetChannelConnected, onTargetChannelSourceDisconnected

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationNodeStateListener

public ReplicationNodeStateListener(SpaceEngine spaceEngine)

Method Detail

onTargetChannelOutOfSync

public boolean onTargetChannelOutOfSync(String groupName,
                                        String channelSourceLookupName,
                                        IncomingReplicationOutOfSyncException outOfSyncReason)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel failed handshake due to becoming out of sync

Returns:

true if the target channel is allowed to resync (and lose data due to resynchronization)

onTargetChannelBacklogDropped

public void onTargetChannelBacklogDropped(String groupName,
                                          String channelSourceLookupName,
                                          IBacklogMemberState memberState)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel received a notice that its backlog was dropped at the source

onSourceBrokenReplicationTopology

public void onSourceBrokenReplicationTopology(String groupName,
                                              String channelTargetMemberName,
                                              BrokenReplicationTopologyException error)

onSourceChannelActivated

public void onSourceChannelActivated(String groupName,
                                     String memberName)

onTargetChannelCreationValidation

public void onTargetChannelCreationValidation(String groupName,
                                              String sourceMemberName,
                                              Object sourceUniqueId)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a new channel is being established, just before the channel is created to allow custom validation logic. An exception will consider the channel creation is invalid, regular return will be considered as valid connection

onNewReplicaRequest

public void onNewReplicaRequest(String groupName,
                                String memberName,
                                boolean isSynchronizeRequest)

Description copied from interface: IReplicationNodeStateListener

Called when new replica request is received, for custom validation