public class NioServer
extends com.google.common.util.concurrent.AbstractExecutionThreadService
StreamConnection
to
process data.Constructor and Description |
---|
NioServer(StreamConnectionFactory connectionFactory,
InetSocketAddress bindAddress)
Creates a new server which is capable of listening for incoming connections and processing client provided data
using
StreamConnection s created by the given StreamConnectionFactory |
Modifier and Type | Method and Description |
---|---|
protected void |
run() |
void |
triggerShutdown()
Invoked by the Execution service when it's time to stop.
|
public NioServer(StreamConnectionFactory connectionFactory, InetSocketAddress bindAddress) throws IOException
StreamConnection
s created by the given StreamConnectionFactory
IOException
- If there is an issue opening the server socket or binding fails for some reasonprotected void run() throws Exception
run
in class com.google.common.util.concurrent.AbstractExecutionThreadService
Exception
public void triggerShutdown()
com.google.common.util.concurrent.AbstractExecutionThreadService#stop()
instead.triggerShutdown
in class com.google.common.util.concurrent.AbstractExecutionThreadService
Copyright © 2018. All rights reserved.