Class SocketConnector

    • Constructor Detail

      • SocketConnector

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

        public SocketConnector​(int processorCount,
                               java.util.concurrent.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 Detail

      • 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​(java.net.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.
        config - the configuration
        Returns:
        ConnectFuture that will tell the result of the connection attempt
      • connect

        public ConnectFuture connect​(java.net.SocketAddress address,
                                     java.net.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.
        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:
        java.lang.NullPointerException - if the specified value is null.