public class ZeroMQTcpClient<IN,OUT> extends TcpClient<IN,OUT>
connectAddress
PING
started
Constructor and Description |
---|
ZeroMQTcpClient(Environment env,
Dispatcher eventsDispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions 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) |
protected Stream<Tuple2<InetSocketAddress,Integer>> |
doStart(ReactorChannelHandler handler,
Reconnect reconnect) |
getConnectAddress, getOptions, getSslOptions
start
getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start
public ZeroMQTcpClient(@Nonnull Environment env, @Nonnull Dispatcher eventsDispatcher, @Nonnull Supplier<InetSocketAddress> connectAddress, @Nullable ClientSocketOptions options, @Nullable SslOptions sslOptions, @Nullable Codec<Buffer,IN,OUT> codec)
protected Stream<Tuple2<InetSocketAddress,Integer>> doStart(ReactorChannelHandler handler, Reconnect reconnect)
doStart
in class ReactorClient<IN,OUT,ChannelStream<IN,OUT>>
protected Promise<Void> doShutdown()
doShutdown
in class ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>
protected ZeroMQChannelStream<IN,OUT> bindChannel()
protected Promise<Void> doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler)
doStart
in class ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>
Copyright © 2017. All rights reserved.