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

Class ReliableAsyncReplicationSourceGroupBuilder

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceGroupBuilder<ReliableAsyncSourceGroupConfig>

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

All Implemented Interfaces:

IReplicationSourceGroupBuilder

public class ReliableAsyncReplicationSourceGroupBuilder
extends AbstractReplicationSourceGroupBuilder<ReliableAsyncSourceGroupConfig>

Constructor Summary

Constructors

Constructor and Description
ReliableAsyncReplicationSourceGroupBuilder(DynamicSourceGroupConfigHolder groupConfig)

Method Summary

Modifier and Type	Method and Description
protected IReplicationSourceGroup	createGroupImpl(DynamicSourceGroupConfigHolder groupConfig, IReplicationRouter replicationRouter, IReplicationOutFilter outFilter, IReplicationSourceGroupStateListener stateListener)
void	setAsyncChannelBatchSize(int asyncChannelBatchSize)
void	setAsyncChannelIntervalMilis(long asyncChannelInterval)
void	setAsyncChannelIntervalOperations(int asyncChannelIntervalOperations)
void	setAsyncHandlerProvider(IAsyncHandlerProvider asyncHandlerProvider)
void	setBacklogBuilder(IReplicationReliableAsyncBacklogBuilder backlogBuilder)
void	setSyncChannelAsyncStateBatchSize(int syncChannelAsyncStateBatchSize)
void	setSyncChannelIdleDelayMilis(long syncChannelIdleDelayMilis)
void	setThrottleController(IReplicationThrottleControllerBuilder throttleController)
String	toString()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceGroupBuilder

createGroup, getGroupConfig

Methods inherited from class java.lang.Object

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

Constructor Detail

ReliableAsyncReplicationSourceGroupBuilder

public ReliableAsyncReplicationSourceGroupBuilder(DynamicSourceGroupConfigHolder groupConfig)

Method Detail

setBacklogBuilder

public void setBacklogBuilder(IReplicationReliableAsyncBacklogBuilder backlogBuilder)

setThrottleController

public void setThrottleController(IReplicationThrottleControllerBuilder throttleController)

setAsyncHandlerProvider

public void setAsyncHandlerProvider(IAsyncHandlerProvider asyncHandlerProvider)

setSyncChannelAsyncStateBatchSize

public void setSyncChannelAsyncStateBatchSize(int syncChannelAsyncStateBatchSize)

setSyncChannelIdleDelayMilis

public void setSyncChannelIdleDelayMilis(long syncChannelIdleDelayMilis)

setAsyncChannelBatchSize

public void setAsyncChannelBatchSize(int asyncChannelBatchSize)

setAsyncChannelIntervalMilis

public void setAsyncChannelIntervalMilis(long asyncChannelInterval)

setAsyncChannelIntervalOperations

public void setAsyncChannelIntervalOperations(int asyncChannelIntervalOperations)

createGroupImpl

protected IReplicationSourceGroup createGroupImpl(DynamicSourceGroupConfigHolder groupConfig,
                                                  IReplicationRouter replicationRouter,
                                                  IReplicationOutFilter outFilter,
                                                  IReplicationSourceGroupStateListener stateListener)

Specified by:

createGroupImpl in class AbstractReplicationSourceGroupBuilder<ReliableAsyncSourceGroupConfig>

toString

public String toString()

Overrides:

toString in class Object