com.gigaspaces.config.lrmi.nio

Class NIOConfiguration

java.lang.Object

com.gigaspaces.config.lrmi.nio.NIOConfiguration

All Implemented Interfaces:

ITransportConfig, Externalizable, Serializable, Cloneable

public class NIOConfiguration
extends Object
implements ITransportConfig, Cloneable, Externalizable

This class provides configuration object of NIO communication transport protocol.

Since:

5.2

Author:

Igor Goldenberg

See Also:

GenericExporter, Serialized Form

Constructor Summary

Constructors

Constructor and Description
NIOConfiguration() Should not be used, only for externalizable.

Method Summary

Modifier and Type	Method and Description
ITransportConfig	clone()
static NIOConfiguration	create() Creates a new instance of NIO configuration based on system properties.
String	getBindHostName()
String	getBindPort()
int	getConnectionPoolSize()
int	getCustomMaxThreads()
int	getCustomMinThreads()
int	getCustomQueueCapacity()
long	getCustomThreadIdleTimeout()
int	getMaxConnPool()
int	getMaxThreads()
int	getMinThreads()
String	getProtocolAdaptorClass()
String	getProtocolName()
int	getReadSelectorThreads()
int	getSlowConsumerLatency()
int	getSlowConsumerReadTimeout()
int	getSlowConsumerRetries()
int	getSlowConsumerThroughput()
long	getSocketConnectTimeout()
int	getSystemPriorityMaxThreads()
int	getSystemPriorityMinThreads()
int	getSystemPriorityQueueCapacity()
long	getSystemPriorityThreadIdleTimeout()
long	getThreadPoolIdleTimeout()
int	getThreadsQueueSize()
long	getWatchdogIdleConnectionTimeout()
long	getWatchdogListeningTimeout()
long	getWatchdogRequestTimeout()
boolean	isBlockingConnection()
boolean	isProtocolValidationEnabled()
void	readExternal(ObjectInput in)
void	setBindHost(String bindHostName)
void	setBindPort(String bindPort)
void	setBlockingConnection(boolean blockingConnection)
void	setMaxConnPool(int maxConnPool)
void	setMaxThreads(int maxThreads)
void	setMinThreads(int minThreads)
void	setSlowConsumerLatency(int slowConsumerLatency)
void	setSlowConsumerReadTimeout(int slowConsumerReadTimeout)
void	setSlowConsumerRetries(int slowConsumerRetries)
void	setSlowConsumerThroughput(int slowConsumerThroughput)
void	setThreadsQueueSize(int threadsQueueSize)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

NIOConfiguration

public NIOConfiguration()

Should not be used, only for externalizable.

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

create

public static NIOConfiguration create()

Creates a new instance of NIO configuration based on system properties.

clone

public ITransportConfig clone()

Specified by:

clone in interface ITransportConfig

Overrides:

clone in class Object

getProtocolAdaptorClass

public String getProtocolAdaptorClass()

Specified by:

getProtocolAdaptorClass in interface ITransportConfig

Returns:

the protocol adaptor classname

getMinThreads

public int getMinThreads()

Specified by:

getMinThreads in interface ITransportConfig

Returns:

The minimal number of transport threads

setMinThreads

public void setMinThreads(int minThreads)

getMaxThreads

public int getMaxThreads()

Specified by:

getMaxThreads in interface ITransportConfig

Returns:

The maximal number of transport threads

setMaxThreads

public void setMaxThreads(int maxThreads)

getThreadsQueueSize

public int getThreadsQueueSize()

Specified by:

getThreadsQueueSize in interface ITransportConfig

Returns:

The threads queue size

setThreadsQueueSize

public void setThreadsQueueSize(int threadsQueueSize)

getConnectionPoolSize

public int getConnectionPoolSize()

Specified by:

getConnectionPoolSize in interface ITransportConfig

Returns:

the connection socket pool size of protocol adaptor

setMaxConnPool

public void setMaxConnPool(int maxConnPool)

setBindHost

public void setBindHost(String bindHostName)

setBindPort

public void setBindPort(String bindPort)

setBlockingConnection

public void setBlockingConnection(boolean blockingConnection)

getMaxConnPool

public int getMaxConnPool()

getBindPort

public String getBindPort()

getBindHostName

public String getBindHostName()

getProtocolName

public final String getProtocolName()

Specified by:

getProtocolName in interface ITransportConfig

Returns:

the protocol adaptor name of underlying transport protocol

isBlockingConnection

public boolean isBlockingConnection()

Specified by:

isBlockingConnection in interface ITransportConfig

Returns:

is blocking connection

getSlowConsumerLatency

public int getSlowConsumerLatency()

Specified by:

getSlowConsumerLatency in interface ITransportConfig

Returns:

Slow Consumer Latency

setSlowConsumerLatency

public void setSlowConsumerLatency(int slowConsumerLatency)

getSlowConsumerRetries

public int getSlowConsumerRetries()

Specified by:

getSlowConsumerRetries in interface ITransportConfig

Returns:

Slow Consumer Retries

setSlowConsumerRetries

public void setSlowConsumerRetries(int slowConsumerRetries)

getSlowConsumerReadTimeout

public int getSlowConsumerReadTimeout()

setSlowConsumerReadTimeout

public void setSlowConsumerReadTimeout(int slowConsumerReadTimeout)

getSlowConsumerThroughput

public int getSlowConsumerThroughput()

Specified by:

getSlowConsumerThroughput in interface ITransportConfig

Returns:

Slow Consumer Throughput

setSlowConsumerThroughput

public void setSlowConsumerThroughput(int slowConsumerThroughput)

getReadSelectorThreads

public int getReadSelectorThreads()

Specified by:

getReadSelectorThreads in interface ITransportConfig

Returns:

Returns the _readSelectorThreads.

getSystemPriorityQueueCapacity

public int getSystemPriorityQueueCapacity()

Specified by:

getSystemPriorityQueueCapacity in interface ITransportConfig

Returns:

LRMI number of system read selector threads

getSystemPriorityThreadIdleTimeout

public long getSystemPriorityThreadIdleTimeout()

Specified by:

getSystemPriorityThreadIdleTimeout in interface ITransportConfig

getSystemPriorityMinThreads

public int getSystemPriorityMinThreads()

getSystemPriorityMaxThreads

public int getSystemPriorityMaxThreads()

getCustomQueueCapacity

public int getCustomQueueCapacity()

getCustomThreadIdleTimeout

public long getCustomThreadIdleTimeout()

getCustomMinThreads

public int getCustomMinThreads()

getCustomMaxThreads

public int getCustomMaxThreads()

getWatchdogRequestTimeout

public long getWatchdogRequestTimeout()

Specified by:

getWatchdogRequestTimeout in interface ITransportConfig

Returns:

Returns the _watchdogRequestTimeout.

getWatchdogListeningTimeout

public long getWatchdogListeningTimeout()

Specified by:

getWatchdogListeningTimeout in interface ITransportConfig

Returns:

Returns the _watchdogListeningTimeout.

getWatchdogIdleConnectionTimeout

public long getWatchdogIdleConnectionTimeout()

Specified by:

getWatchdogIdleConnectionTimeout in interface ITransportConfig

Returns:

Returns the _watchdogIdleConnectionTimeout.

getThreadPoolIdleTimeout

public long getThreadPoolIdleTimeout()

Specified by:

getThreadPoolIdleTimeout in interface ITransportConfig

Returns:

LRMI ThreadPool idle timeout

getSocketConnectTimeout

public long getSocketConnectTimeout()

Specified by:

getSocketConnectTimeout in interface ITransportConfig

Returns:

The timeout on lrmi socket connect

isProtocolValidationEnabled

public boolean isProtocolValidationEnabled()

toString

public String toString()

Overrides:

toString in class Object