|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ListeningIOReactor
ListeningIOReactor represents an I/O reactor capable of listening for incoming connections on one or several ports.
Method Summary | |
---|---|
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. |
void |
resume()
Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints. |
Methods inherited from interface org.apache.http.nio.reactor.IOReactor |
---|
execute, getStatus, shutdown, shutdown |
Method Detail |
---|
ListenerEndpoint listen(SocketAddress address)
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.
address
- the socket address to listen on.
void pause() throws IOException
IOException
- in case of an I/O error.void resume() throws IOException
IOException
- in case of an I/O error.Set<ListenerEndpoint> getEndpoints()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |