Class SocketConnector

All Implemented Interfaces:
IoConnector, IoService

public class SocketConnector extends BaseIoConnector
IoConnector for socket transport (TCP/IP).
  • Constructor Details

    • SocketConnector

      public SocketConnector()
      Create a connector with a single processing thread using a NewThreadExecutor
    • SocketConnector

      public SocketConnector(int processorCount, Executor executor)
      Create a connector with the desired number of processing threads
      Parameters:
      processorCount - Number of processing threads
      executor - Executor to use for launching threads
  • Method Details

    • getWorkerTimeout

      public int getWorkerTimeout()
      How many seconds to keep the connection thread alive between connection requests
      Returns:
      the number of seconds to keep connection thread alive. 0 means that the connection thread will terminate immediately when there's no connection to make.
    • setWorkerTimeout

      public void setWorkerTimeout(int workerTimeout)
      Set how many seconds the connection worker thread should remain alive once idle before terminating itself.
      Parameters:
      workerTimeout - the number of seconds to keep thread alive. Must be >=0. If 0 is specified, the connection worker thread will terminate immediately when there's no connection to make.
    • connect

      public ConnectFuture connect(SocketAddress address, IoHandler handler, IoServiceConfig config)
      Description copied from interface: IoConnector
      Connects to the specified address. If communication starts successfully, events are fired to the specified handler.
      Parameters:
      config - the configuration
      Returns:
      ConnectFuture that will tell the result of the connection attempt
    • connect

      public ConnectFuture connect(SocketAddress address, SocketAddress localAddress, IoHandler handler, IoServiceConfig config)
      Description copied from interface: IoConnector
      Connects to the specified address. If communication starts successfully, events are fired to the specified handler.
      Parameters:
      config - the configuration
      Returns:
      ConnectFuture that will tell the result of the connection attempt
    • getDefaultConfig

      public SocketConnectorConfig getDefaultConfig()
      Description copied from interface: IoService
      Returns the default configuration which is used when you didn't specify any configuration.
    • setDefaultConfig

      public void setDefaultConfig(SocketConnectorConfig defaultConfig)
      Sets the config this connector will use by default.
      Parameters:
      defaultConfig - the default config.
      Throws:
      NullPointerException - if the specified value is null.