public class Options
extends java.lang.Object
Constructor and Description |
---|
Options() |
Modifier and Type | Method and Description |
---|---|
private MsgAllocator |
allocator(java.lang.Class<?> clazz) |
private <T> java.lang.Class<? extends T> |
checkCustomCodec(java.lang.Object optval,
java.lang.Class<T> type) |
private SelectorProviderChooser |
chooser(java.lang.Class<?> clazz) |
java.lang.Object |
getSocketOpt(int option) |
static boolean |
parseBoolean(int option,
java.lang.Object optval) |
static byte[] |
parseBytes(int option,
java.lang.Object optval) |
static java.lang.String |
parseString(int option,
java.lang.Object optval) |
private byte[] |
setCurveKey(int option,
java.lang.Object optval,
ValueReference<java.lang.Boolean> result) |
boolean |
setSocketOpt(int option,
java.lang.Object optval) |
public int sendHwm
public int recvHwm
public long affinity
public short identitySize
public byte[] identity
java.lang.String lastEndpoint
int rate
int recoveryIvl
int multicastHops
public int sndbuf
public int rcvbuf
public int tos
public int type
public int linger
public int reconnectIvl
public int reconnectIvlMax
public int backlog
public long maxMsgSize
int recvTimeout
int sendTimeout
public boolean ipv6
public boolean immediate
public boolean filter
public boolean recvIdentity
public boolean rawSocket
public java.lang.String socksProxyAddress
public int tcpKeepAlive
public int tcpKeepAliveCnt
public int tcpKeepAliveIdle
public int tcpKeepAliveIntvl
public final java.util.List<TcpAddress.TcpAddressMask> tcpAcceptFilters
final java.util.List<IpcAddress.IpcAddressMask> ipcAcceptFilters
public Mechanisms mechanism
public boolean asServer
public java.lang.String zapDomain
public java.lang.String plainUsername
public java.lang.String plainPassword
public static final int CURVE_KEYSIZE
public static final int CURVE_KEYSIZE_Z85
public byte[] curvePublicKey
public byte[] curveSecretKey
public byte[] curveServerKey
java.lang.String gssPrincipal
java.lang.String gssServicePrincipal
boolean gssPlaintext
public int socketId
public boolean conflate
public int handshakeIvl
public int heartbeatTtl
public int heartbeatInterval
public int heartbeatTimeout
public byte[] heartbeatContext
public java.lang.Class<? extends IDecoder> decoder
public java.lang.Class<? extends IEncoder> encoder
public MsgAllocator allocator
public SelectorProviderChooser selectorChooser
public Msg helloMsg
public boolean canSendHelloMsg
public Msg disconnectMsg
public boolean canReceiveDisconnectMsg
public Msg hiccupMsg
public boolean canReceiveHiccupMsg
public int asType
public int peerLastRoutingId
public final Errno errno
public boolean setSocketOpt(int option, java.lang.Object optval)
private MsgAllocator allocator(java.lang.Class<?> clazz)
private SelectorProviderChooser chooser(java.lang.Class<?> clazz)
private <T> java.lang.Class<? extends T> checkCustomCodec(java.lang.Object optval, java.lang.Class<T> type)
private byte[] setCurveKey(int option, java.lang.Object optval, ValueReference<java.lang.Boolean> result)
public java.lang.Object getSocketOpt(int option)
public static boolean parseBoolean(int option, java.lang.Object optval)
public static java.lang.String parseString(int option, java.lang.Object optval)
public static byte[] parseBytes(int option, java.lang.Object optval)