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

Class SourceDelegationReplicationReliableAsyncMediator

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.reliableasync.SourceDelegationReplicationReliableAsyncMediator

All Implemented Interfaces:

IReplicationReliableAsyncMediator

public class SourceDelegationReplicationReliableAsyncMediator
extends Object
implements IReplicationReliableAsyncMediator

Delegates synchronization issues to the source in order to get a solution

Since:

8.0.5

Author:

eitany

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor

Description

SourceDelegationReplicationReliableAsyncMediator(DynamicReliableAsyncSourceGroupConfigHolder groupConfigHolder, IReplicationConnection sourceConnection, IReplicationReliableAsyncGroupBacklog reliableAsyncGroupBacklog, String sourceLookupName, String myLookupName, IReplicationRouter router, IReplicationChannelDataFilterBuilder filterBuilder, IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)

Method Summary

Modifier and Type	Method	Description
void	afterHandshake(IProcessLogHandshakeResponse response)
IMarker	getMarker(IReplicationOrderedPacket packet, String membersGroupName)
void	performCompaction()
void	reliableAsyncSourceAdd(String sourceLookupName, IReplicationOrderedPacket packet)
void	reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)
void	updateReliableAsyncState(IReliableAsyncState reliableAsyncState, String sourceMemberName)

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

Constructor Details

SourceDelegationReplicationReliableAsyncMediator

public SourceDelegationReplicationReliableAsyncMediator(DynamicReliableAsyncSourceGroupConfigHolder groupConfigHolder,
 IReplicationConnection sourceConnection,
 IReplicationReliableAsyncGroupBacklog reliableAsyncGroupBacklog,
 String sourceLookupName,
 String myLookupName,
 IReplicationRouter router,
 IReplicationChannelDataFilterBuilder filterBuilder,
 IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)

Method Details

reliableAsyncSourceAdd

public void reliableAsyncSourceAdd(String sourceLookupName,
 IReplicationOrderedPacket packet)

Specified by:

reliableAsyncSourceAdd in interface IReplicationReliableAsyncMediator

reliableAsyncSourceKeep

public void reliableAsyncSourceKeep(String sourceMemberName,
 IReplicationOrderedPacket packet)

Specified by:

reliableAsyncSourceKeep in interface IReplicationReliableAsyncMediator

afterHandshake

public void afterHandshake(IProcessLogHandshakeResponse response)

Specified by:

afterHandshake in interface IReplicationReliableAsyncMediator

updateReliableAsyncState

public void updateReliableAsyncState(IReliableAsyncState reliableAsyncState,
 String sourceMemberName)

Specified by:

updateReliableAsyncState in interface IReplicationReliableAsyncMediator

getMarker

public IMarker getMarker(IReplicationOrderedPacket packet,
 String membersGroupName)

Specified by:

getMarker in interface IReplicationReliableAsyncMediator

performCompaction

public void performCompaction()

Specified by:

performCompaction in interface IReplicationReliableAsyncMediator