IN
- The type that will be received by this serverOUT
- The type that will be sent by this serverpublic class NettyTcpServer<IN,OUT> extends TcpServer<IN,OUT>
TcpServer
implementationlistenAddress
started
Modifier | Constructor and Description |
---|---|
protected |
NettyTcpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Modifier and Type | Method and Description |
---|---|
protected void |
bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
io.netty.channel.socket.SocketChannel nativeChannel) |
Promise<Void> |
doShutdown() |
protected Promise<Void> |
doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
getListenAddress, getOptions, getSslOptions
getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start
protected NettyTcpServer(Environment env, Dispatcher dispatcher, InetSocketAddress listenAddress, ServerSocketOptions options, SslOptions sslOptions, Codec<Buffer,IN,OUT> codec)
protected Promise<Void> doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler)
doStart
in class ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>
public Promise<Void> doShutdown()
doShutdown
in class ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>
protected void bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler, io.netty.channel.socket.SocketChannel nativeChannel)
Copyright © 2016. All rights reserved.