org.apache.http.impl.nio.reactor
Class DefaultListeningIOReactor
java.lang.Object
org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
org.apache.http.impl.nio.reactor.DefaultListeningIOReactor
- All Implemented Interfaces:
- IOReactor, ListeningIOReactor
- public class DefaultListeningIOReactor
- extends AbstractMultiworkerIOReactor
- implements ListeningIOReactor
Constructor Summary |
DefaultListeningIOReactor(int workerCount,
org.apache.http.params.HttpParams params)
|
DefaultListeningIOReactor(int workerCount,
org.apache.http.util.concurrent.ThreadFactory threadFactory,
org.apache.http.params.HttpParams params)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TIMEOUT_CHECK_INTERVAL
public static int TIMEOUT_CHECK_INTERVAL
DefaultListeningIOReactor
public DefaultListeningIOReactor(int workerCount,
org.apache.http.util.concurrent.ThreadFactory threadFactory,
org.apache.http.params.HttpParams params)
throws IOReactorException
DefaultListeningIOReactor
public DefaultListeningIOReactor(int workerCount,
org.apache.http.params.HttpParams params)
throws IOReactorException
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-2007 Apache Software Foundation. All Rights Reserved.