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

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

public class DefaultConnectingIOReactor
extends AbstractMultiworkerIOReactor
implements ConnectingIOReactor


Field Summary
 
Fields inherited from class org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
exceptionHandler, params, selector, selectTimeout, status
 
Constructor Summary
DefaultConnectingIOReactor(int workerCount, org.apache.http.params.HttpParams params)
           
DefaultConnectingIOReactor(int workerCount, java.util.concurrent.ThreadFactory threadFactory, org.apache.http.params.HttpParams params)
           
 
Method Summary
protected  void cancelRequests()
           
 SessionRequest connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, java.lang.Object attachment, SessionRequestCallback callback)
           
protected  void processEvents(int readyCount)
           
 
Methods inherited from class org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
addChannel, awaitShutdown, doShutdown, execute, getStatus, prepareSocket, registerChannel, setExceptionHandler, shutdown, shutdown
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.http.nio.reactor.IOReactor
execute, getStatus, shutdown, shutdown
 

Constructor Detail

DefaultConnectingIOReactor

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

DefaultConnectingIOReactor

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

cancelRequests

protected void cancelRequests()
                       throws IOReactorException
Specified by:
cancelRequests in class AbstractMultiworkerIOReactor
Throws:
IOReactorException

processEvents

protected void processEvents(int readyCount)
                      throws IOReactorException
Specified by:
processEvents in class AbstractMultiworkerIOReactor
Throws:
IOReactorException

connect

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


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