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


Constructor Summary
DefaultListeningIOReactor(int workerCount, HttpParams params)
           
DefaultListeningIOReactor(int workerCount, ThreadFactory threadFactory, HttpParams params)
           
 
Method Summary
 void execute(IOEventDispatch eventDispatch)
           
 java.net.SocketAddress listen(java.net.SocketAddress address)
           
protected  void prepareSocket(java.net.Socket socket)
           
 void setExceptionHandler(IOReactorExceptionHandler exceptionHandler)
           
 void shutdown()
           
 
Methods inherited from class org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
addChannel, getSelectTimeout, startWorkers, stopWorkers, verifyWorkers
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultListeningIOReactor

public DefaultListeningIOReactor(int workerCount,
                                 ThreadFactory threadFactory,
                                 HttpParams params)
                          throws IOReactorException
Throws:
IOReactorException

DefaultListeningIOReactor

public DefaultListeningIOReactor(int workerCount,
                                 HttpParams params)
                          throws IOReactorException
Throws:
IOReactorException
Method Detail

setExceptionHandler

public void setExceptionHandler(IOReactorExceptionHandler exceptionHandler)

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

listen

public java.net.SocketAddress listen(java.net.SocketAddress address)
                              throws java.io.IOException
Specified by:
listen in interface ListeningIOReactor
Throws:
java.io.IOException

shutdown

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


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