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

Class SourceGroupConfig<T extends SourceChannelConfig>

java.lang.Object

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

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

Direct Known Subclasses:

AsyncSourceGroupConfig

public class SourceGroupConfig<T extends SourceChannelConfig>
extends GroupConfig

Constructor Summary

Constructors

Constructor and Description
SourceGroupConfig(String groupName, BacklogConfig backlogConfig, GroupConsistencyLevelPolicy groupConsistencyLevelPolicy, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Map<String,String[]> membersGrouping, String... membersLookupNames)
SourceGroupConfig(String groupName, BacklogConfig backlogConfig, String... membersLookupNames)

Method Summary

Modifier and Type	Method and Description
void	addMembersGrouping(String groupName, String... memberNames)
BacklogConfig	getBacklogConfig()
T	getChannelConfig(String memberName)
IReplicationChannelDataFilter	getFilter(String memberLookupName)
Map<String,IReplicationChannelDataFilter>	getFilters()
GroupConsistencyLevelPolicy	getGroupConsistencyLevelPolicy()
long	getInconsistentStateDelay()
int	getInconsistentStateRetries()
DynamicSourceGroupMemberLifeCycle	getLifeCycle(String memberName)
Map<String,DynamicSourceGroupMemberLifeCycle>	getLifeCycles()
Map<String,String[]>	getMembersGrouping()
void	setChannelConfig(String memberName, T config)
void	setInconsistentStateDelay(long inconsistentStateDelay)
void	setInconsistentStateRetries(int inconsistentStateRetries)
String	toString()

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

getHistoryLength, getMembersLookupNames, getName, setHistoryLength

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceGroupConfig

public SourceGroupConfig(String groupName,
                         BacklogConfig backlogConfig,
                         String... membersLookupNames)

SourceGroupConfig

public SourceGroupConfig(String groupName,
                         BacklogConfig backlogConfig,
                         GroupConsistencyLevelPolicy groupConsistencyLevelPolicy,
                         Map<String,IReplicationChannelDataFilter> filters,
                         Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles,
                         Map<String,String[]> membersGrouping,
                         String... membersLookupNames)

Method Detail

getBacklogConfig

public BacklogConfig getBacklogConfig()

getFilter

public IReplicationChannelDataFilter getFilter(String memberLookupName)

getFilters

public Map<String,IReplicationChannelDataFilter> getFilters()

getInconsistentStateDelay

public long getInconsistentStateDelay()

setInconsistentStateDelay

public void setInconsistentStateDelay(long inconsistentStateDelay)

getInconsistentStateRetries

public int getInconsistentStateRetries()

setInconsistentStateRetries

public void setInconsistentStateRetries(int inconsistentStateRetries)

setChannelConfig

public void setChannelConfig(String memberName,
                             T config)

getChannelConfig

public T getChannelConfig(String memberName)

addMembersGrouping

public void addMembersGrouping(String groupName,
                               String... memberNames)

getMembersGrouping

public Map<String,String[]> getMembersGrouping()

getLifeCycle

public DynamicSourceGroupMemberLifeCycle getLifeCycle(String memberName)

getLifeCycles

public Map<String,DynamicSourceGroupMemberLifeCycle> getLifeCycles()

getGroupConsistencyLevelPolicy

public GroupConsistencyLevelPolicy getGroupConsistencyLevelPolicy()

toString

public String toString()

Overrides:

toString in class GroupConfig