reactor.io.net.impl.zmq.tcp

Class ZeroMQTcpServer<IN,OUT>

java.lang.Object

reactor.io.net.ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>

reactor.io.net.tcp.TcpServer<IN,OUT>

reactor.io.net.impl.zmq.tcp.ZeroMQTcpServer<IN,OUT>

public class ZeroMQTcpServer<IN,OUT>
extends TcpServer<IN,OUT>

Author:

Jon Brisbin, Stephane Maldini

Field Summary

Fields inherited from class reactor.io.net.tcp.TcpServer

listenAddress

Fields inherited from class reactor.io.net.ReactorPeer

started

Constructor Summary

Constructors

Constructor and Description
ZeroMQTcpServer(Environment env, Dispatcher eventsDispatcher, InetSocketAddress listenAddress, ServerSocketOptions options, SslOptions sslOptions, Codec<Buffer,IN,OUT> codec)

Method Summary

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)

Methods inherited from class reactor.io.net.tcp.TcpServer

getListenAddress, getOptions, getSslOptions

Methods inherited from class reactor.io.net.ReactorPeer

getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZeroMQTcpServer

public ZeroMQTcpServer(Environment env,
                       Dispatcher eventsDispatcher,
                       InetSocketAddress listenAddress,
                       ServerSocketOptions options,
                       SslOptions sslOptions,
                       Codec<Buffer,IN,OUT> codec)

Method Detail

doStart

protected Promise<Void> doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler)

Specified by:

doStart in class ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>

bindChannel

protected ZeroMQChannelStream<IN,OUT> bindChannel()

doShutdown

protected Promise<Void> doShutdown()

Specified by:

doShutdown in class ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>