public class ZeroMQClientSocketOptions extends ClientSocketOptions
ClientSocketOptions
that include ZeroMQ-specific configuration options.Constructor and Description |
---|
ZeroMQClientSocketOptions() |
Modifier and Type | Method and Description |
---|---|
String |
connectAddresses() |
ZeroMQClientSocketOptions |
connectAddresses(String connectAddresses) |
org.zeromq.ZContext |
context()
Get the
ZContext to use for IO. |
ZeroMQClientSocketOptions |
context(org.zeromq.ZContext context)
Set the
ZContext to use for IO. |
Consumer<org.zeromq.ZMQ.Socket> |
socketConfigurer()
The
Consumer responsible for configuring the underlying ZeroMQ socket. |
ZeroMQClientSocketOptions |
socketConfigurer(Consumer<org.zeromq.ZMQ.Socket> socketConfigurer)
Set the
Consumer responsible for configure the underlying ZeroMQ socket. |
int |
socketType()
The type of the ZMQ socket to create.
|
ZeroMQClientSocketOptions |
socketType(int socketType)
Set the type of ZMQ socket to create.
|
keepAlive, keepAlive, linger, linger, prefetch, prefetch, rcvbuf, rcvbuf, sndbuf, sndbuf, tcpNoDelay, tcpNoDelay, timeout, timeout
public org.zeromq.ZContext context()
ZContext
to use for IO.ZContext
to usepublic ZeroMQClientSocketOptions context(org.zeromq.ZContext context)
ZContext
to use for IO.context
- the ZContext
to usepublic int socketType()
public ZeroMQClientSocketOptions socketType(int socketType)
socketType
- the ZMQ socket typepublic Consumer<org.zeromq.ZMQ.Socket> socketConfigurer()
Consumer
responsible for configuring the underlying ZeroMQ socket.public ZeroMQClientSocketOptions socketConfigurer(Consumer<org.zeromq.ZMQ.Socket> socketConfigurer)
Consumer
responsible for configure the underlying ZeroMQ socket.socketConfigurer
- the ZMQ.Socket configurerpublic String connectAddresses()
public ZeroMQClientSocketOptions connectAddresses(String connectAddresses)
Copyright © 2016. All rights reserved.