Package com.gigaspaces.internal.cluster.node.impl.groups

Class AbstractReplicationTargetChannel

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationTargetChannel

All Implemented Interfaces:

IReplicationInFilterCallback, IReplicationTargetChannel, IConnectionStateListener, IConnectivityCheckListener

Direct Known Subclasses:

AsyncReplicationTargetChannel, SyncReplicationTargetChannel

public abstract class AbstractReplicationTargetChannel
extends Object
implements IReplicationInFilterCallback, IReplicationTargetChannel, IConnectionStateListener, IConnectivityCheckListener

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.slf4j.Logger	_specificLogger
protected final org.slf4j.Logger	_specificVerboseLogger

Constructor Summary

Constructors

Constructor

Description

AbstractReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory, boolean wasEverActive)

Method Summary

Modifier and Type	Method	Description
void	afterSuccessfulConnectivityCheck()
void	close(long channelCloseTimeout, TimeUnit unit)
String	dumpState()
long	getLastProcessTimeStamp()
String	getMyLookupName()
IReplicationTargetProcessLog	getProcessLog()
Object	getSourceEndpointAddress()
String	getSourceLookupName()
Object	getSourceUniqueId()
void	invokeInFilter(IReplicationInContext context, IReplicationPacketData<?> data)	Callback method for the data consumer to invoke input filters before executing the packet
boolean	isSourceAttached()
protected void	logEventInHistory(String event)
void	onChannelBacklogDropped(String groupName, IBacklogMemberState memberState, IReplicationTargetGroupStateListener listener)
void	onConnected(boolean newTarget)
void	onDisconnected()
protected String	onDumpState()
IProcessLogHandshakeResponse	performHandshake(IBacklogHandshakeRequest handshakeRequest)
Object	process(IReplicationOrderedPacket packet)
Object	processBatch(List<IReplicationOrderedPacket> packets)
void	processHandshakeIteration(IHandshakeIteration handshakeIteration)
Object	processIdleStateData(IIdleStateData idleStateData)

Methods inherited from class java.lang.Object

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

Field Details

_specificLogger

protected final org.slf4j.Logger _specificLogger

_specificVerboseLogger

protected final org.slf4j.Logger _specificVerboseLogger

Constructor Details

AbstractReplicationTargetChannel

public AbstractReplicationTargetChannel(TargetGroupConfig groupConfig,
 String myLookupName,
 Object myUniqueId,
 ReplicationEndpointDetails sourceEndpointDetails,
 IReplicationMonitoredConnection sourceConnection,
 String groupName,
 IReplicationTargetProcessLog processLog,
 IReplicationInFilter inFilter,
 IReplicationTargetGroupStateListener groupStateListener,
 IReplicationGroupHistory groupHistory,
 boolean wasEverActive)

Method Details

getProcessLog

public IReplicationTargetProcessLog getProcessLog()

Specified by:

getProcessLog in interface IReplicationTargetChannel

getSourceLookupName

public String getSourceLookupName()

getMyLookupName

public String getMyLookupName()

getSourceUniqueId

public Object getSourceUniqueId()

processBatch

public Object processBatch(List<IReplicationOrderedPacket> packets)

processIdleStateData

public Object processIdleStateData(IIdleStateData idleStateData)

process

public Object process(IReplicationOrderedPacket packet)

invokeInFilter

public void invokeInFilter(IReplicationInContext context,
 IReplicationPacketData<?> data)

Description copied from interface: IReplicationInFilterCallback

Callback method for the data consumer to invoke input filters before executing the packet

Specified by:

invokeInFilter in interface IReplicationInFilterCallback

performHandshake

public IProcessLogHandshakeResponse performHandshake(IBacklogHandshakeRequest handshakeRequest)

processHandshakeIteration

public void processHandshakeIteration(IHandshakeIteration handshakeIteration)

close

public void close(long channelCloseTimeout,
 TimeUnit unit)

isSourceAttached

public boolean isSourceAttached()

onChannelBacklogDropped

public void onChannelBacklogDropped(String groupName,
 IBacklogMemberState memberState,
 IReplicationTargetGroupStateListener listener)

onDumpState

protected String onDumpState()

dumpState

public String dumpState()

logEventInHistory

protected void logEventInHistory(String event)

onConnected

public void onConnected(boolean newTarget)

Specified by:

onConnected in interface IConnectionStateListener

afterSuccessfulConnectivityCheck

public void afterSuccessfulConnectivityCheck()

Specified by:

afterSuccessfulConnectivityCheck in interface IConnectivityCheckListener

onDisconnected

public void onDisconnected()

Specified by:

onDisconnected in interface IConnectionStateListener

getSourceEndpointAddress

public Object getSourceEndpointAddress()

getLastProcessTimeStamp

public long getLastProcessTimeStamp()