Package com.gigaspaces.config.lrmi.nio

Class NIOConfiguration

java.lang.Object
com.gigaspaces.config.lrmi.nio.NIOConfiguration
All Implemented Interfaces:
ITransportConfig, SmartExternalizable, Externalizable, Serializable, Cloneable
public class NIOConfiguration extends Object implements ITransportConfig, Cloneable, SmartExternalizable
This class provides configuration object of NIO communication transport protocol.
Since:
5.2
Author:
Igor Goldenberg
See Also:

  • Field Details

  • Constructor Details

    • NIOConfiguration

      public NIOConfiguration()
      Should not be used, only for externalizable.

  • Method Details

    • 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