Interface ConnectionAcceptor

All Known Implementing Classes:
AsyncServer, DefaultListeningIOReactor, HttpAsyncServer, SingleCoreListeningIOReactor

public interface ConnectionAcceptor
Non-blocking connection acceptor.
Since:
5.0
  • Method Details

    • listen

      default Future<ListenerEndpoint> listen(SocketAddress address, Object attachment, 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.
      attachment - the attachment object.
      callback - the result callback.
      Returns:
      listener endpoint.
      Since:
      5.2
    • listen

      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.