Package org.apache.hc.core5.reactor
Interface ConnectionAcceptor
- All Known Implementing Classes:
AsyncServer
,DefaultListeningIOReactor
,HttpAsyncServer
,SingleCoreListeningIOReactor
public interface ConnectionAcceptor
Non-blocking connection acceptor.
- Since:
- 5.0
-
Method Summary
Modifier and TypeMethodDescriptionReturns a set of endpoints for this I/O reactor.default Future
<ListenerEndpoint> listen
(SocketAddress address, Object attachment, FutureCallback<ListenerEndpoint> callback) Opens a new listener endpoint with the given socket address.listen
(SocketAddress address, FutureCallback<ListenerEndpoint> callback) 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.
-
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
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
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.
-