com.gigaspaces.internal.client.cache.localview.replication

Class ReplicationLocalViewStateListener

java.lang.Object

com.gigaspaces.internal.cluster.node.AbstractReplicationNodeStateListener

com.gigaspaces.internal.client.cache.localview.replication.ReplicationLocalViewStateListener

All Implemented Interfaces:

IReplicationSourceGroupStateListener, IReplicationTargetGroupStateListener, IReplicationNodeStateListener

public class ReplicationLocalViewStateListener
extends AbstractReplicationNodeStateListener

Since:

8.0.5

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor and Description
ReplicationLocalViewStateListener(ReplicationLocalView localView, LocalViewConfig viewConfig)

Method Summary

Modifier and Type	Method and Description
boolean	isHealthy()
void	onNewReplicaRequest(String groupName, String channelName, 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	onSynchronizationCompleted()
void	onTargetChannelBacklogDropped(String groupName, String channelSourceLooString, IBacklogMemberState memberState) Called when a target channel received a notice that its backlog was dropped at the source
void	onTargetChannelConnected(String groupName, String sourceMemberName, Object sourceUniqueId) Called when a target channel is connected/created
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
void	onTargetChannelSourceDisconnected(String groupName, String sourceMemberName, Object sourceUniqueId) Called when a target channel lost connection to its source
void	setDisconnectedState(int numOfPartitions)

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

onReplicationNodeModeChange

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationLocalViewStateListener

public ReplicationLocalViewStateListener(ReplicationLocalView localView,
                                         LocalViewConfig viewConfig)

Method Detail

isHealthy

public boolean isHealthy()

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 channelSourceLooString,
                                          IBacklogMemberState memberState)

Description copied from interface: IReplicationTargetGroupStateListener

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

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

setDisconnectedState

public void setDisconnectedState(int numOfPartitions)

onTargetChannelSourceDisconnected

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

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel lost connection to its source

Specified by:

onTargetChannelSourceDisconnected in interface IReplicationTargetGroupStateListener

Overrides:

onTargetChannelSourceDisconnected in class AbstractReplicationNodeStateListener

onTargetChannelConnected

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

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel is connected/created

Specified by:

onTargetChannelConnected in interface IReplicationTargetGroupStateListener

Overrides:

onTargetChannelConnected in class AbstractReplicationNodeStateListener

onSourceBrokenReplicationTopology

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

onSourceChannelActivated

public void onSourceChannelActivated(String groupName,
                                     String memberName)

onNewReplicaRequest

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

Description copied from interface: IReplicationNodeStateListener

Called when new replica request is received, for custom validation

onSynchronizationCompleted

public void onSynchronizationCompleted()
                                throws SpaceCacheInitializationException

Throws:

SpaceCacheInitializationException