org.apache.mina.transport.socket.nio
Class ExistingSocketConnector

java.lang.Object
  extended by org.apache.mina.common.support.BaseIoService
      extended by org.apache.mina.common.support.BaseIoConnector
          extended by org.apache.mina.transport.socket.nio.ExistingSocketConnector
All Implemented Interfaces:
org.apache.mina.common.IoConnector, org.apache.mina.common.IoService

public class ExistingSocketConnector
extends org.apache.mina.common.support.BaseIoConnector

IoConnector for socket transport (TCP/IP).

Version:
$Rev: 627427 $, $Date: 2008-02-13 14:39:10 +0000 (Wed, 13 Feb 2008) $

Constructor Summary
ExistingSocketConnector()
          Create a connector with a single processing thread using a NewThreadExecutor
ExistingSocketConnector(int processorCount, edu.emory.mathcs.backport.java.util.concurrent.Executor executor)
          Create a connector with the desired number of processing threads
 
Method Summary
 org.apache.mina.common.ConnectFuture connect(SocketAddress address, org.apache.mina.common.IoHandler handler, org.apache.mina.common.IoServiceConfig config)
           
 org.apache.mina.common.ConnectFuture connect(SocketAddress address, SocketAddress localAddress, org.apache.mina.common.IoHandler handler, org.apache.mina.common.IoServiceConfig config)
           
 org.apache.mina.common.IoServiceConfig getDefaultConfig()
           
 int getWorkerTimeout()
          How many seconds to keep the connection thread alive between connection requests
 void setDefaultConfig(org.apache.mina.transport.socket.nio.SocketConnectorConfig defaultConfig)
          Sets the config this connector will use by default.
 void setOpenSocket(Socket openSocket)
           
 void setWorkerTimeout(int workerTimeout)
          Set how many seconds the connection worker thread should remain alive once idle before terminating itself.
 
Methods inherited from class org.apache.mina.common.support.BaseIoConnector
connect, connect
 
Methods inherited from class org.apache.mina.common.support.BaseIoService
addListener, getFilterChain, getFilterChainBuilder, getListeners, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.mina.common.IoService
addListener, getFilterChain, getFilterChainBuilder, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder
 

Constructor Detail

ExistingSocketConnector

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


ExistingSocketConnector

public ExistingSocketConnector(int processorCount,
                               edu.emory.mathcs.backport.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:
Number of seconds to keep connection thread alive

setWorkerTimeout

public void setWorkerTimeout(int workerTimeout)
Set how many seconds the connection worker thread should remain alive once idle before terminating itself.

Parameters:
workerTimeout - Number of seconds to keep thread alive. Must be >=0

connect

public org.apache.mina.common.ConnectFuture connect(SocketAddress address,
                                                    org.apache.mina.common.IoHandler handler,
                                                    org.apache.mina.common.IoServiceConfig config)

connect

public org.apache.mina.common.ConnectFuture connect(SocketAddress address,
                                                    SocketAddress localAddress,
                                                    org.apache.mina.common.IoHandler handler,
                                                    org.apache.mina.common.IoServiceConfig config)

getDefaultConfig

public org.apache.mina.common.IoServiceConfig getDefaultConfig()

setDefaultConfig

public void setDefaultConfig(org.apache.mina.transport.socket.nio.SocketConnectorConfig defaultConfig)
Sets the config this connector will use by default.

Parameters:
defaultConfig - the default config.
Throws:
NullPointerException - if the specified value is null.

setOpenSocket

public void setOpenSocket(Socket openSocket)


Licensed to the Apache Software Foundation