public interface ConnectionAcceptor
Modifier and Type | Method and Description |
---|---|
Set<ListenerEndpoint> |
getEndpoints()
Returns a set of endpoints for this I/O reactor.
|
Future<ListenerEndpoint> |
listen(SocketAddress address,
FutureCallback<ListenerEndpoint> callback)
Opens a new listener endpoint with the given socket address.
|
default Future<ListenerEndpoint> |
listen(SocketAddress address,
Object attachment,
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.
|
default Future<ListenerEndpoint> listen(SocketAddress address, Object attachment, FutureCallback<ListenerEndpoint> callback)
address
- the socket address to listen on.attachment
- the attachment object.callback
- the result callback.Future<ListenerEndpoint> listen(SocketAddress address, FutureCallback<ListenerEndpoint> callback)
address
- the socket address to listen on.callback
- the result callback.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()
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.