public interface

ListeningIOReactor

implements IOReactor
org.apache.http.nio.reactor.ListeningIOReactor
Known Indirect Subclasses

Class Overview

ListeningIOReactor represents an I/O reactor capable of listening for incoming connections on one or several ports.

Summary

Public Methods
abstract Set<ListenerEndpoint> getEndpoints()
Returns a set of endpoints for this I/O reactor.
abstract ListenerEndpoint listen(SocketAddress address)
Opens a new listener endpoint with the given socket address.
abstract void pause()
Suspends the I/O reactor preventing it from accepting new connections on all active endpoints.
abstract void resume()
Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints.
[Expand]
Inherited Methods
From interface org.apache.http.nio.reactor.IOReactor

Public Methods

public abstract Set<ListenerEndpoint> getEndpoints ()

Returns a set of endpoints for this I/O reactor.

Returns
  • set of endpoints.

public abstract ListenerEndpoint listen (SocketAddress address)

Opens a new listener endpoint with the given socket address. Once the endpoint is fully initialized it starts accepting incoming connections and propagates I/O activity notifications to the I/O event dispatcher.

waitFor() can be used to wait for the listener to be come ready to accept incoming connections.

close() can be used to shut down the listener even before it is fully initialized.

Parameters
address the socket address to listen on.
Returns
  • listener endpoint.

public abstract void pause ()

Suspends the I/O reactor preventing it from accepting new connections on all active endpoints.

Throws
IOException in case of an I/O error.

public abstract void resume ()

Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints.

Throws
IOException in case of an I/O error.