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

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

public class DefaultListeningIOReactor
extends AbstractMultiworkerIOReactor
implements ListeningIOReactor


Field Summary
 
Fields inherited from class org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
exceptionHandler, params, selector, selectTimeout, status
 
Constructor Summary
DefaultListeningIOReactor(int workerCount, org.apache.http.params.HttpParams params)
           
DefaultListeningIOReactor(int workerCount, java.util.concurrent.ThreadFactory threadFactory, org.apache.http.params.HttpParams params)
           
 
Method Summary
protected  void cancelRequests()
           
 java.util.Set<ListenerEndpoint> getEndpoints()
           
 ListenerEndpoint listen(java.net.SocketAddress address)
           
 void pause()
           
protected  void processEvents(int readyCount)
           
 void resume()
           
 
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

DefaultListeningIOReactor

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

DefaultListeningIOReactor

public DefaultListeningIOReactor(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

listen

public ListenerEndpoint listen(java.net.SocketAddress address)
Specified by:
listen in interface ListeningIOReactor

getEndpoints

public java.util.Set<ListenerEndpoint> getEndpoints()
Specified by:
getEndpoints in interface ListeningIOReactor

pause

public void pause()
           throws java.io.IOException
Specified by:
pause in interface ListeningIOReactor
Throws:
java.io.IOException

resume

public void resume()
            throws java.io.IOException
Specified by:
resume in interface ListeningIOReactor
Throws:
java.io.IOException


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