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

Class ReliableAsyncSourceGroupConfig

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.config.SourceGroupConfig<AsyncChannelConfig>

com.gigaspaces.internal.cluster.node.impl.groups.async.AsyncSourceGroupConfig

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

public class ReliableAsyncSourceGroupConfig
extends AsyncSourceGroupConfig

Constructor Summary

Constructors

Constructor	Description
ReliableAsyncSourceGroupConfig(String groupName, BacklogConfig backlogConfig, GroupConsistencyLevelPolicy groupConsistencyLevelPolicy, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Map<String,String[]> membersGrouping, String[] syncMembersLookupNames, String[] asyncMembersLookupNames, int backlogCompletionBatchSize, long completionNotifierInterval, long completionNotifierPacketsThreshold)
ReliableAsyncSourceGroupConfig(String groupName, BacklogConfig backlogConfig, GroupConsistencyLevelPolicy groupConsistencyLevelPolicy, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Map<String,String[]> membersGrouping, String[] syncMembersLookupNames, String[] asyncMembersLookupNames, int backlogCompletionBatchSize, long completionNotifierInterval, long completionNotifierPacketsThreshold, boolean networkCompressionEnabled)

Method Summary

Modifier and Type	Method	Description
String[]	getAsyncMembersLookupNames()
int	getBacklogCompletionBatchSize()
long	getCompletionNotifierInterval()
long	getCompletionNotifierPacketsThreshold()
String[]	getSyncMembersLookupNames()
String	toString()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.config.SourceGroupConfig

addMembersGrouping, getBacklogConfig, getChannelConfig, getFilter, getFilters, getGroupConsistencyLevelPolicy, getInconsistentStateDelay, getInconsistentStateRetries, getLifeCycle, getLifeCycles, getMembersGrouping, setChannelConfig, setInconsistentStateDelay, setInconsistentStateRetries

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.config.GroupConfig

getHistoryLength, getMembersLookupNames, getName, isNetworkCompressionEnabled, setEnableNetworkCompression, setHistoryLength

Methods inherited from class java.lang.Object

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

Constructor Details

ReliableAsyncSourceGroupConfig

public ReliableAsyncSourceGroupConfig(String groupName,
 BacklogConfig backlogConfig,
 GroupConsistencyLevelPolicy groupConsistencyLevelPolicy,
 Map<String,IReplicationChannelDataFilter> filters,
 Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles,
 Map<String,String[]> membersGrouping,
 String[] syncMembersLookupNames,
 String[] asyncMembersLookupNames,
 int backlogCompletionBatchSize,
 long completionNotifierInterval,
 long completionNotifierPacketsThreshold)

ReliableAsyncSourceGroupConfig

public ReliableAsyncSourceGroupConfig(String groupName,
 BacklogConfig backlogConfig,
 GroupConsistencyLevelPolicy groupConsistencyLevelPolicy,
 Map<String,IReplicationChannelDataFilter> filters,
 Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles,
 Map<String,String[]> membersGrouping,
 String[] syncMembersLookupNames,
 String[] asyncMembersLookupNames,
 int backlogCompletionBatchSize,
 long completionNotifierInterval,
 long completionNotifierPacketsThreshold,
 boolean networkCompressionEnabled)

Method Details

getSyncMembersLookupNames

public String[] getSyncMembersLookupNames()

getAsyncMembersLookupNames

public String[] getAsyncMembersLookupNames()

getBacklogCompletionBatchSize

public int getBacklogCompletionBatchSize()

getCompletionNotifierInterval

public long getCompletionNotifierInterval()

getCompletionNotifierPacketsThreshold

public long getCompletionNotifierPacketsThreshold()

toString

public String toString()

Overrides:

toString in class AsyncSourceGroupConfig