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

Class AsyncChannelConfig

java.lang.Object

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

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

All Implemented Interfaces:

SmartExternalizable, Externalizable, Serializable

public class AsyncChannelConfig
extends SourceChannelConfig

Since:

8.0.3

See Also:

• Serialized Form

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.config.SourceChannelConfig

UNLIMITED

Constructor Summary

Constructors

Constructor	Description
AsyncChannelConfig()
AsyncChannelConfig(int batchSize, long intervalMilis, int intervalOperations, ReplicationStatistics.ReplicationMode channelType)
AsyncChannelConfig(int batchSize, long intervalMilis, int intervalOperations, ReplicationStatistics.ReplicationMode channelType, long maxAllowedDisconnectionTimeBeforeDrop)

Method Summary

Modifier and Type	Method	Description
int	getBatchSize()
ReplicationStatistics.ReplicationMode	getChannelType()
long	getIntervalMilis()
int	getIntervalOperations()
String	getTag()
void	readExternal(ObjectInput in)
void	setTag(String tag)
void	writeExternal(ObjectOutput out)

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

getMaxAllowedDisconnectionTimeBeforeDrop

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

AsyncChannelConfig

public AsyncChannelConfig()

AsyncChannelConfig

public AsyncChannelConfig(int batchSize,
 long intervalMilis,
 int intervalOperations,
 ReplicationStatistics.ReplicationMode channelType)

AsyncChannelConfig

public AsyncChannelConfig(int batchSize,
 long intervalMilis,
 int intervalOperations,
 ReplicationStatistics.ReplicationMode channelType,
 long maxAllowedDisconnectionTimeBeforeDrop)

Method Details

setTag

public void setTag(String tag)

Parameters:

tag - a name to identify the channel target.

Since:

14.5

getTag

public String getTag()

Returns:

a name/id/tag identifying the channel target.

Since:

14.5

getChannelType

public ReplicationStatistics.ReplicationMode getChannelType()

getBatchSize

public int getBatchSize()

getIntervalMilis

public long getIntervalMilis()

getIntervalOperations

public int getIntervalOperations()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SourceChannelConfig

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SourceChannelConfig

Throws:

IOException

ClassNotFoundException