|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
org.apache.http.impl.nio.reactor.DefaultListeningIOReactor
@ThreadSafe public class DefaultListeningIOReactor
Default implementation of ListeningIOReactor. This class extends
AbstractMultiworkerIOReactor with capability to listen for incoming
connections.
| Field Summary |
|---|
| Fields inherited from class org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor |
|---|
auditLog, config, exceptionHandler, interestOpsQueueing, params, selector, selectTimeout, status |
| Constructor Summary | |
|---|---|
DefaultListeningIOReactor()
Creates an instance of DefaultListeningIOReactor with default configuration. |
|
DefaultListeningIOReactor(int workerCount,
HttpParams params)
Deprecated. (4.2) use DefaultListeningIOReactor(IOReactorConfig) |
|
DefaultListeningIOReactor(int workerCount,
ThreadFactory threadFactory,
HttpParams params)
Deprecated. (4.2) use DefaultListeningIOReactor(IOReactorConfig, ThreadFactory) |
|
DefaultListeningIOReactor(IOReactorConfig config)
Creates an instance of DefaultListeningIOReactor with the given configuration. |
|
DefaultListeningIOReactor(IOReactorConfig config,
ThreadFactory threadFactory)
Creates an instance of DefaultListeningIOReactor with the given configuration. |
|
| Method Summary | |
|---|---|
protected void |
cancelRequests()
Triggered to cancel pending session requests. |
Set<ListenerEndpoint> |
getEndpoints()
Returns a set of endpoints for this I/O reactor. |
ListenerEndpoint |
listen(SocketAddress address)
Opens a new listener endpoint with the given socket address. |
void |
pause()
Suspends the I/O reactor preventing it from accepting new connections on all active endpoints. |
protected void |
processEvents(int readyCount)
Triggered to process I/O events registered by the main Selector. |
void |
resume()
Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints. |
| Methods inherited from class org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor |
|---|
addChannel, addExceptionEvent, addExceptionEvent, awaitShutdown, doShutdown, execute, getAuditLog, 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 |
|---|
public DefaultListeningIOReactor(IOReactorConfig config,
ThreadFactory threadFactory)
throws IOReactorException
config - I/O reactor configuration.threadFactory - the factory to create threads.
Can be null.
IOReactorException - in case if a non-recoverable I/O error.
public DefaultListeningIOReactor(IOReactorConfig config)
throws IOReactorException
config - I/O reactor configuration.
Can be null.
IOReactorException - in case if a non-recoverable I/O error.
public DefaultListeningIOReactor()
throws IOReactorException
IOReactorException - in case if a non-recoverable I/O error.
@Deprecated
public DefaultListeningIOReactor(int workerCount,
ThreadFactory threadFactory,
HttpParams params)
throws IOReactorException
DefaultListeningIOReactor(IOReactorConfig, ThreadFactory)
IOReactorException
@Deprecated
public DefaultListeningIOReactor(int workerCount,
HttpParams params)
throws IOReactorException
DefaultListeningIOReactor(IOReactorConfig)
IOReactorException| Method Detail |
|---|
protected void cancelRequests()
throws IOReactorException
AbstractMultiworkerIOReactorSuper-classes can implement this method to react to the event.
cancelRequests in class AbstractMultiworkerIOReactorIOReactorException - in case if a non-recoverable I/O error.
protected void processEvents(int readyCount)
throws IOReactorException
AbstractMultiworkerIOReactorSelector.
Super-classes can implement this method to react to the event.
processEvents in class AbstractMultiworkerIOReactorreadyCount - event count.
IOReactorException - in case if a non-recoverable I/O error.public ListenerEndpoint listen(SocketAddress address)
ListeningIOReactor
ListenerEndpoint.waitFor() can be used to wait for the
listener to be come ready to accept incoming connections.
ListenerEndpoint.close() can be used to shut down
the listener even before it is fully initialized.
listen in interface ListeningIOReactoraddress - the socket address to listen on.
public Set<ListenerEndpoint> getEndpoints()
ListeningIOReactor
getEndpoints in interface ListeningIOReactor
public void pause()
throws IOException
ListeningIOReactor
pause in interface ListeningIOReactorIOException - in case of an I/O error.
public void resume()
throws IOException
ListeningIOReactor
resume in interface ListeningIOReactorIOException - in case of an I/O error.
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||