public class ZeroMQTcpServer<IN,OUT> extends TcpServer<IN,OUT>
listenAddress
started
Constructor and Description |
---|
ZeroMQTcpServer(Environment env,
Dispatcher eventsDispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Modifier and Type | Method and Description |
---|---|
protected ZeroMQChannelStream<IN,OUT> |
bindChannel() |
protected Promise<Void> |
doShutdown() |
protected Promise<Void> |
doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
getListenAddress, getOptions, getSslOptions
getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start
public ZeroMQTcpServer(Environment env, Dispatcher eventsDispatcher, 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>>
protected ZeroMQChannelStream<IN,OUT> bindChannel()
protected Promise<Void> doShutdown()
doShutdown
in class ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>
Copyright © 2016. All rights reserved.