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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
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.