com.gigaspaces.internal.cluster.node.impl.config

Class MirrorReplicationSettingsAdapter

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.config.MirrorReplicationSettingsAdapter

All Implemented Interfaces:

IMirrorChannelReplicationSettings, IReplicationSettings

public class MirrorReplicationSettingsAdapter
extends Object
implements IMirrorChannelReplicationSettings

Constructor Summary

Constructors

Constructor and Description
MirrorReplicationSettingsAdapter(MirrorServiceConfig policy)

Method Summary

Modifier and Type	Method and Description
String	getBacklogWeightPolicy()
int	getBatchParallelFactor()
int	getBatchParallelThreshold()
int	getBatchSize()
short	getBucketCount()
long	getConsumeTimeout()
long	getIdleDelay()
IReplicationInFilter	getInFilter()
BacklogConfig.LimitReachedPolicy	getLimitReachedPolicy()
long	getMaxRedoLogCapacity()
String	getMirrorMemberName()
int	getOperationsReplicationThreshold()
IReplicationOutFilter	getOutFilter()
ReplicationProcessingType	getProcessingType()
ISpaceCopyReplicaInFilter	getSpaceCopyInFilter()
ISpaceCopyReplicaOutFilter	getSpaceCopyOutFilter()
Set<String>	getSupportedChangeOperations()
SwapBacklogConfig	getSwapBacklogSettings()
ISyncReplicationSettings	getSyncReplicationSettings()
boolean	isMirrorServiceEnabled()
boolean	isOneWay()
boolean	isReliableAsyncRepl()
boolean	isSync()
boolean	supportsChange()

Methods inherited from class java.lang.Object

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

Constructor Detail

MirrorReplicationSettingsAdapter

public MirrorReplicationSettingsAdapter(MirrorServiceConfig policy)

Method Detail

getMirrorMemberName

public String getMirrorMemberName()

Specified by:

getMirrorMemberName in interface IMirrorChannelReplicationSettings

getIdleDelay

public long getIdleDelay()

Specified by:

getIdleDelay in interface IReplicationSettings

getOperationsReplicationThreshold

public int getOperationsReplicationThreshold()

Specified by:

getOperationsReplicationThreshold in interface IReplicationSettings

getLimitReachedPolicy

public BacklogConfig.LimitReachedPolicy getLimitReachedPolicy()

Specified by:

getLimitReachedPolicy in interface IReplicationSettings

getMaxRedoLogCapacity

public long getMaxRedoLogCapacity()

Specified by:

getMaxRedoLogCapacity in interface IReplicationSettings

isReliableAsyncRepl

public boolean isReliableAsyncRepl()

isMirrorServiceEnabled

public boolean isMirrorServiceEnabled()

isSync

public boolean isSync()

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface IReplicationSettings

getOutFilter

public IReplicationOutFilter getOutFilter()

Specified by:

getOutFilter in interface IReplicationSettings

getInFilter

public IReplicationInFilter getInFilter()

Specified by:

getInFilter in interface IReplicationSettings

getSpaceCopyInFilter

public ISpaceCopyReplicaInFilter getSpaceCopyInFilter()

Specified by:

getSpaceCopyInFilter in interface IReplicationSettings

getSpaceCopyOutFilter

public ISpaceCopyReplicaOutFilter getSpaceCopyOutFilter()

Specified by:

getSpaceCopyOutFilter in interface IReplicationSettings

isOneWay

public boolean isOneWay()

getSyncReplicationSettings

public ISyncReplicationSettings getSyncReplicationSettings()

Specified by:

getSyncReplicationSettings in interface IReplicationSettings

getProcessingType

public ReplicationProcessingType getProcessingType()

Specified by:

getProcessingType in interface IReplicationSettings

getBucketCount

public short getBucketCount()

Specified by:

getBucketCount in interface IReplicationSettings

getBatchParallelFactor

public int getBatchParallelFactor()

Specified by:

getBatchParallelFactor in interface IReplicationSettings

getBatchParallelThreshold

public int getBatchParallelThreshold()

Specified by:

getBatchParallelThreshold in interface IReplicationSettings

getConsumeTimeout

public long getConsumeTimeout()

Specified by:

getConsumeTimeout in interface IReplicationSettings

getSwapBacklogSettings

public SwapBacklogConfig getSwapBacklogSettings()

Specified by:

getSwapBacklogSettings in interface IReplicationSettings

getBacklogWeightPolicy

public String getBacklogWeightPolicy()

Specified by:

getBacklogWeightPolicy in interface IReplicationSettings

supportsChange

public boolean supportsChange()

Specified by:

supportsChange in interface IMirrorChannelReplicationSettings

getSupportedChangeOperations

public Set<String> getSupportedChangeOperations()

Specified by:

getSupportedChangeOperations in interface IMirrorChannelReplicationSettings