com.gigaspaces.internal.events.durable

Class DurableNotificationReplicationNodeStateListener

java.lang.Object

com.gigaspaces.internal.events.durable.DurableNotificationReplicationNodeStateListener

All Implemented Interfaces:

IReplicationSourceGroupStateListener, IReplicationTargetGroupStateListener, IReplicationNodeStateListener

public class DurableNotificationReplicationNodeStateListener
extends Object
implements IReplicationNodeStateListener

Since:

9.0

Author:

Dan Kilman

Constructor Summary

Constructors

Constructor and Description
DurableNotificationReplicationNodeStateListener(EventSessionConfig config, DurableNotificationLease lease, IAsyncHandlerProvider asyncProvider, int numOfPartitions, int partitionId)

Method Summary

Modifier and Type	Method and Description
void	close()
void	onNewReplicaRequest(String groupName, String channelName, boolean isSynchronizeRequest) Called when new replica request is received, for custom validation
void	onReplicationNodeModeChange(ReplicationNodeMode newMode) Called when replication node mode has changed.
void	onSourceBrokenReplicationTopology(String groupName, String channelTargetMemberName, BrokenReplicationTopologyException error)
void	onSourceChannelActivated(String groupName, String memberName)
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	startDisconnectionMonitoring()

Methods inherited from class java.lang.Object

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

Constructor Detail

DurableNotificationReplicationNodeStateListener

public DurableNotificationReplicationNodeStateListener(EventSessionConfig config,
                                                       DurableNotificationLease lease,
                                                       IAsyncHandlerProvider asyncProvider,
                                                       int numOfPartitions,
                                                       int partitionId)

Method Detail

startDisconnectionMonitoring

public void startDisconnectionMonitoring()

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

Specified by:

onTargetChannelOutOfSync in interface IReplicationTargetGroupStateListener

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

Specified by:

onTargetChannelBacklogDropped in interface IReplicationTargetGroupStateListener

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

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

onReplicationNodeModeChange

public void onReplicationNodeModeChange(ReplicationNodeMode newMode)

Description copied from interface: IReplicationNodeStateListener

Called when replication node mode has changed.

Specified by:

onReplicationNodeModeChange in interface IReplicationNodeStateListener

close

public void close()

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

Specified by:

onTargetChannelCreationValidation in interface IReplicationTargetGroupStateListener

onSourceBrokenReplicationTopology

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

Specified by:

onSourceBrokenReplicationTopology in interface IReplicationSourceGroupStateListener

onSourceChannelActivated

public void onSourceChannelActivated(String groupName,
                                     String memberName)

Specified by:

onSourceChannelActivated in interface IReplicationSourceGroupStateListener

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

Specified by:

onNewReplicaRequest in interface IReplicationNodeStateListener