Method Detail

• listen

  Future<ListenerEndpoint> listen(SocketAddress address,
                                FutureCallback<ListenerEndpoint> callback)

  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.

  Parameters:

  address - the socket address to listen on.

  callback - the result callback.

  Returns:

  listener endpoint.

• pause

  void pause()
             throws IOException

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

  Throws:

  IOException - in case of an I/O error.

• resume

  void resume()
              throws IOException

  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.

• getEndpoints

  Set<ListenerEndpoint> getEndpoints()

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

  Returns:

  set of endpoints.