org.apache.http.impl.nio.reactor
Class DefaultConnectingIOReactor

java.lang.Object
  extended byorg.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
      extended byorg.apache.http.impl.nio.reactor.DefaultConnectingIOReactor
All Implemented Interfaces:
ConnectingIOReactor, IOReactor

public class DefaultConnectingIOReactor
extends AbstractMultiworkerIOReactor
implements ConnectingIOReactor


Field Summary
static int TIMEOUT_CHECK_INTERVAL
           
 
Constructor Summary
DefaultConnectingIOReactor(int workerCount, org.apache.http.params.HttpParams params)
           
DefaultConnectingIOReactor(int workerCount, org.apache.http.util.concurrent.ThreadFactory threadFactory, org.apache.http.params.HttpParams params)
           
 
Method Summary
 SessionRequest connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, java.lang.Object attachment, SessionRequestCallback callback)
           
 void execute(IOEventDispatch eventDispatch)
           
protected  void prepareSocket(java.net.Socket socket)
           
 void shutdown()
           
 
Methods inherited from class org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
addChannel, startWorkers, stopWorkers, verifyWorkers
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TIMEOUT_CHECK_INTERVAL

public static int TIMEOUT_CHECK_INTERVAL
Constructor Detail

DefaultConnectingIOReactor

public DefaultConnectingIOReactor(int workerCount,
                                  org.apache.http.util.concurrent.ThreadFactory threadFactory,
                                  org.apache.http.params.HttpParams params)
                           throws IOReactorException

DefaultConnectingIOReactor

public DefaultConnectingIOReactor(int workerCount,
                                  org.apache.http.params.HttpParams params)
                           throws IOReactorException
Method Detail

execute

public void execute(IOEventDispatch eventDispatch)
             throws java.io.InterruptedIOException,
                    IOReactorException
Specified by:
execute in interface IOReactor
Throws:
java.io.InterruptedIOException
IOReactorException

prepareSocket

protected void prepareSocket(java.net.Socket socket)
                      throws java.io.IOException
Throws:
java.io.IOException

connect

public SessionRequest connect(java.net.SocketAddress remoteAddress,
                              java.net.SocketAddress localAddress,
                              java.lang.Object attachment,
                              SessionRequestCallback callback)
Specified by:
connect in interface ConnectingIOReactor

shutdown

public void shutdown()
              throws java.io.IOException
Specified by:
shutdown in interface IOReactor
Throws:
java.io.IOException


Copyright © 2005-2007 Apache Software Foundation. All Rights Reserved.