Package zmq
Class ZMQ
- java.lang.Object
-
- zmq.ZMQ
-
public class ZMQ extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ZMQ.Event
-
Field Summary
-
Constructor Summary
Constructors Constructor Description ZMQ()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static boolean
bind(SocketBase s, java.lang.String addr)
private static void
checkContext(Ctx ctx)
private static void
checkSocket(SocketBase s)
static void
close(SocketBase s)
static void
closeZeroLinger(SocketBase s)
static boolean
connect(SocketBase s, java.lang.String addr)
static int
connectPeer(SocketBase s, java.lang.String addr)
static Ctx
createContext()
private static void
destroyContext(Ctx ctx)
static boolean
device(int device, SocketBase frontend, SocketBase backend)
static boolean
disconnect(SocketBase s, java.lang.String addr)
static boolean
disconnectPeer(SocketBase s, int routingId)
static int
getContextOption(Ctx ctx, int option)
java.lang.String
getMessageGroup(Msg msg)
static java.lang.String
getMessageMetadata(Msg msg, java.lang.String property)
static int
getMessageOption(Msg msg, int option)
int
getMessageRoutingId(Msg msg)
static int
getSocketOption(SocketBase s, int opt)
static java.lang.Object
getSocketOptionExt(SocketBase s, int option)
static Ctx
init(int ioThreads)
static boolean
join(SocketBase s, java.lang.String group)
static boolean
leave(SocketBase s, java.lang.String group)
static int
makeVersion(int major, int minor, int patch)
static boolean
monitorSocket(SocketBase s, java.lang.String addr, int events)
static Msg
msgInit()
static Msg
msgInitWithSize(int messageSize)
static int
msgSize(Msg msg)
static void
msleep(long milliseconds)
static int
poll(java.nio.channels.Selector selector, PollItem[] items, int count, long timeout)
Polling on items with given selector CAUTION: This could be affected by jdk epoll bugstatic int
poll(java.nio.channels.Selector selector, PollItem[] items, long timeout)
Polling on items with given selector CAUTION: This could be affected by jdk epoll bugstatic boolean
proxy(SocketBase frontend, SocketBase backend, SocketBase capture)
static boolean
proxy(SocketBase frontend, SocketBase backend, SocketBase capture, SocketBase control)
static Msg
recv(SocketBase s, int flags)
int
recviov(SocketBase s, byte[][] a, int count, int flags)
static Msg
recvMsg(SocketBase s, int flags)
static int
send(SocketBase s, byte[] buf, int flags)
static int
send(SocketBase s, byte[] buf, int len, int flags)
static int
send(SocketBase s, java.lang.String str, int flags)
static int
send(SocketBase s, Msg msg, int flags)
int
sendiov(SocketBase s, byte[][] a, int count, int flags)
static boolean
sendMsg(SocketBase socket, byte[]... data)
static int
sendMsg(SocketBase s, Msg msg, int flags)
static void
setContextOption(Ctx ctx, int option, int optval)
boolean
setMessageGroup(Msg msg, java.lang.String group)
boolean
setMessageRoutingId(Msg msg, int routingId)
static boolean
setSocketOption(SocketBase s, int option, java.lang.Object optval)
static void
sleep(long seconds)
static void
sleep(long amount, java.util.concurrent.TimeUnit unit)
static SocketBase
socket(Ctx ctx, int type)
static long
startStopwatch()
static long
stopStopwatch(long watch)
static java.lang.String
strerror(int errno)
static void
term(Ctx ctx)
static boolean
unbind(SocketBase s, java.lang.String addr)
-
-
-
Field Detail
-
ZMQ_VERSION_MAJOR
public static final int ZMQ_VERSION_MAJOR
- See Also:
- Constant Field Values
-
ZMQ_VERSION_MINOR
public static final int ZMQ_VERSION_MINOR
- See Also:
- Constant Field Values
-
ZMQ_VERSION_PATCH
public static final int ZMQ_VERSION_PATCH
- See Also:
- Constant Field Values
-
ZMQ_IO_THREADS
public static final int ZMQ_IO_THREADS
- See Also:
- Constant Field Values
-
ZMQ_MAX_SOCKETS
public static final int ZMQ_MAX_SOCKETS
- See Also:
- Constant Field Values
-
ZMQ_IO_THREADS_DFLT
public static final int ZMQ_IO_THREADS_DFLT
- See Also:
- Constant Field Values
-
ZMQ_MAX_SOCKETS_DFLT
public static final int ZMQ_MAX_SOCKETS_DFLT
- See Also:
- Constant Field Values
-
ZMQ_PAIR
public static final int ZMQ_PAIR
- See Also:
- Constant Field Values
-
ZMQ_PUB
public static final int ZMQ_PUB
- See Also:
- Constant Field Values
-
ZMQ_SUB
public static final int ZMQ_SUB
- See Also:
- Constant Field Values
-
ZMQ_REQ
public static final int ZMQ_REQ
- See Also:
- Constant Field Values
-
ZMQ_REP
public static final int ZMQ_REP
- See Also:
- Constant Field Values
-
ZMQ_DEALER
public static final int ZMQ_DEALER
- See Also:
- Constant Field Values
-
ZMQ_ROUTER
public static final int ZMQ_ROUTER
- See Also:
- Constant Field Values
-
ZMQ_PULL
public static final int ZMQ_PULL
- See Also:
- Constant Field Values
-
ZMQ_PUSH
public static final int ZMQ_PUSH
- See Also:
- Constant Field Values
-
ZMQ_XPUB
public static final int ZMQ_XPUB
- See Also:
- Constant Field Values
-
ZMQ_XSUB
public static final int ZMQ_XSUB
- See Also:
- Constant Field Values
-
ZMQ_STREAM
public static final int ZMQ_STREAM
- See Also:
- Constant Field Values
-
ZMQ_SERVER
public static final int ZMQ_SERVER
- See Also:
- Constant Field Values
-
ZMQ_CLIENT
public static final int ZMQ_CLIENT
- See Also:
- Constant Field Values
-
ZMQ_RADIO
public static final int ZMQ_RADIO
- See Also:
- Constant Field Values
-
ZMQ_DISH
public static final int ZMQ_DISH
- See Also:
- Constant Field Values
-
ZMQ_CHANNEL
public static final int ZMQ_CHANNEL
- See Also:
- Constant Field Values
-
ZMQ_PEER
public static final int ZMQ_PEER
- See Also:
- Constant Field Values
-
ZMQ_RAW
public static final int ZMQ_RAW
- See Also:
- Constant Field Values
-
ZMQ_SCATTER
public static final int ZMQ_SCATTER
- See Also:
- Constant Field Values
-
ZMQ_GATHER
public static final int ZMQ_GATHER
- See Also:
- Constant Field Values
-
ZMQ_XREQ
@Deprecated public static final int ZMQ_XREQ
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_XREP
@Deprecated public static final int ZMQ_XREP
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_CUSTOM_OPTION
private static final int ZMQ_CUSTOM_OPTION
- See Also:
- Constant Field Values
-
ZMQ_AFFINITY
public static final int ZMQ_AFFINITY
- See Also:
- Constant Field Values
-
ZMQ_IDENTITY
public static final int ZMQ_IDENTITY
- See Also:
- Constant Field Values
-
ZMQ_SUBSCRIBE
public static final int ZMQ_SUBSCRIBE
- See Also:
- Constant Field Values
-
ZMQ_UNSUBSCRIBE
public static final int ZMQ_UNSUBSCRIBE
- See Also:
- Constant Field Values
-
ZMQ_RATE
public static final int ZMQ_RATE
- See Also:
- Constant Field Values
-
ZMQ_RECOVERY_IVL
public static final int ZMQ_RECOVERY_IVL
- See Also:
- Constant Field Values
-
ZMQ_SNDBUF
public static final int ZMQ_SNDBUF
- See Also:
- Constant Field Values
-
ZMQ_RCVBUF
public static final int ZMQ_RCVBUF
- See Also:
- Constant Field Values
-
ZMQ_RCVMORE
public static final int ZMQ_RCVMORE
- See Also:
- Constant Field Values
-
ZMQ_FD
public static final int ZMQ_FD
- See Also:
- Constant Field Values
-
ZMQ_EVENTS
public static final int ZMQ_EVENTS
- See Also:
- Constant Field Values
-
ZMQ_TYPE
public static final int ZMQ_TYPE
- See Also:
- Constant Field Values
-
ZMQ_LINGER
public static final int ZMQ_LINGER
- See Also:
- Constant Field Values
-
ZMQ_RECONNECT_IVL
public static final int ZMQ_RECONNECT_IVL
- See Also:
- Constant Field Values
-
ZMQ_BACKLOG
public static final int ZMQ_BACKLOG
- See Also:
- Constant Field Values
-
ZMQ_RECONNECT_IVL_MAX
public static final int ZMQ_RECONNECT_IVL_MAX
- See Also:
- Constant Field Values
-
ZMQ_MAXMSGSIZE
public static final int ZMQ_MAXMSGSIZE
- See Also:
- Constant Field Values
-
ZMQ_SNDHWM
public static final int ZMQ_SNDHWM
- See Also:
- Constant Field Values
-
ZMQ_RCVHWM
public static final int ZMQ_RCVHWM
- See Also:
- Constant Field Values
-
ZMQ_MULTICAST_HOPS
public static final int ZMQ_MULTICAST_HOPS
- See Also:
- Constant Field Values
-
ZMQ_RCVTIMEO
public static final int ZMQ_RCVTIMEO
- See Also:
- Constant Field Values
-
ZMQ_SNDTIMEO
public static final int ZMQ_SNDTIMEO
- See Also:
- Constant Field Values
-
ZMQ_LAST_ENDPOINT
public static final int ZMQ_LAST_ENDPOINT
- See Also:
- Constant Field Values
-
ZMQ_ROUTER_MANDATORY
public static final int ZMQ_ROUTER_MANDATORY
- See Also:
- Constant Field Values
-
ZMQ_TCP_KEEPALIVE
public static final int ZMQ_TCP_KEEPALIVE
- See Also:
- Constant Field Values
-
ZMQ_TCP_KEEPALIVE_CNT
public static final int ZMQ_TCP_KEEPALIVE_CNT
- See Also:
- Constant Field Values
-
ZMQ_TCP_KEEPALIVE_IDLE
public static final int ZMQ_TCP_KEEPALIVE_IDLE
- See Also:
- Constant Field Values
-
ZMQ_TCP_KEEPALIVE_INTVL
public static final int ZMQ_TCP_KEEPALIVE_INTVL
- See Also:
- Constant Field Values
-
ZMQ_IMMEDIATE
public static final int ZMQ_IMMEDIATE
- See Also:
- Constant Field Values
-
ZMQ_XPUB_VERBOSE
public static final int ZMQ_XPUB_VERBOSE
- See Also:
- Constant Field Values
-
ZMQ_ROUTER_RAW
public static final int ZMQ_ROUTER_RAW
- See Also:
- Constant Field Values
-
ZMQ_IPV6
public static final int ZMQ_IPV6
- See Also:
- Constant Field Values
-
ZMQ_MECHANISM
public static final int ZMQ_MECHANISM
- See Also:
- Constant Field Values
-
ZMQ_PLAIN_SERVER
public static final int ZMQ_PLAIN_SERVER
- See Also:
- Constant Field Values
-
ZMQ_PLAIN_USERNAME
public static final int ZMQ_PLAIN_USERNAME
- See Also:
- Constant Field Values
-
ZMQ_PLAIN_PASSWORD
public static final int ZMQ_PLAIN_PASSWORD
- See Also:
- Constant Field Values
-
ZMQ_CURVE_SERVER
public static final int ZMQ_CURVE_SERVER
- See Also:
- Constant Field Values
-
ZMQ_CURVE_PUBLICKEY
public static final int ZMQ_CURVE_PUBLICKEY
- See Also:
- Constant Field Values
-
ZMQ_CURVE_SECRETKEY
public static final int ZMQ_CURVE_SECRETKEY
- See Also:
- Constant Field Values
-
ZMQ_CURVE_SERVERKEY
public static final int ZMQ_CURVE_SERVERKEY
- See Also:
- Constant Field Values
-
ZMQ_PROBE_ROUTER
public static final int ZMQ_PROBE_ROUTER
- See Also:
- Constant Field Values
-
ZMQ_REQ_CORRELATE
public static final int ZMQ_REQ_CORRELATE
- See Also:
- Constant Field Values
-
ZMQ_REQ_RELAXED
public static final int ZMQ_REQ_RELAXED
- See Also:
- Constant Field Values
-
ZMQ_CONFLATE
public static final int ZMQ_CONFLATE
- See Also:
- Constant Field Values
-
ZMQ_ZAP_DOMAIN
public static final int ZMQ_ZAP_DOMAIN
- See Also:
- Constant Field Values
-
ZMQ_ROUTER_HANDOVER
public static final int ZMQ_ROUTER_HANDOVER
- See Also:
- Constant Field Values
-
ZMQ_TOS
public static final int ZMQ_TOS
- See Also:
- Constant Field Values
-
ZMQ_CONNECT_RID
public static final int ZMQ_CONNECT_RID
- See Also:
- Constant Field Values
-
ZMQ_GSSAPI_SERVER
public static final int ZMQ_GSSAPI_SERVER
- See Also:
- Constant Field Values
-
ZMQ_GSSAPI_PRINCIPAL
public static final int ZMQ_GSSAPI_PRINCIPAL
- See Also:
- Constant Field Values
-
ZMQ_GSSAPI_SERVICE_PRINCIPAL
public static final int ZMQ_GSSAPI_SERVICE_PRINCIPAL
- See Also:
- Constant Field Values
-
ZMQ_GSSAPI_PLAINTEXT
public static final int ZMQ_GSSAPI_PLAINTEXT
- See Also:
- Constant Field Values
-
ZMQ_HANDSHAKE_IVL
public static final int ZMQ_HANDSHAKE_IVL
- See Also:
- Constant Field Values
-
ZMQ_SOCKS_PROXY
public static final int ZMQ_SOCKS_PROXY
- See Also:
- Constant Field Values
-
ZMQ_XPUB_NODROP
public static final int ZMQ_XPUB_NODROP
- See Also:
- Constant Field Values
-
ZMQ_BLOCKY
public static final int ZMQ_BLOCKY
- See Also:
- Constant Field Values
-
ZMQ_XPUB_MANUAL
public static final int ZMQ_XPUB_MANUAL
- See Also:
- Constant Field Values
-
ZMQ_HEARTBEAT_IVL
public static final int ZMQ_HEARTBEAT_IVL
- See Also:
- Constant Field Values
-
ZMQ_HEARTBEAT_TTL
public static final int ZMQ_HEARTBEAT_TTL
- See Also:
- Constant Field Values
-
ZMQ_HEARTBEAT_TIMEOUT
public static final int ZMQ_HEARTBEAT_TIMEOUT
- See Also:
- Constant Field Values
-
ZMQ_XPUB_VERBOSER
public static final int ZMQ_XPUB_VERBOSER
- See Also:
- Constant Field Values
-
ZMQ_XPUB_VERBOSE_UNSUBSCRIBE
@Deprecated public static final int ZMQ_XPUB_VERBOSE_UNSUBSCRIBE
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_HELLO_MSG
public static final int ZMQ_HELLO_MSG
- See Also:
- Constant Field Values
-
ZMQ_AS_TYPE
public static final int ZMQ_AS_TYPE
- See Also:
- Constant Field Values
-
ZMQ_DISCONNECT_MSG
public static final int ZMQ_DISCONNECT_MSG
- See Also:
- Constant Field Values
-
ZMQ_HICCUP_MSG
public static final int ZMQ_HICCUP_MSG
- See Also:
- Constant Field Values
-
ZMQ_ENCODER
@Deprecated public static final int ZMQ_ENCODER
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_DECODER
@Deprecated public static final int ZMQ_DECODER
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_MSG_ALLOCATOR
public static final int ZMQ_MSG_ALLOCATOR
- See Also:
- Constant Field Values
-
ZMQ_MSG_ALLOCATION_HEAP_THRESHOLD
public static final int ZMQ_MSG_ALLOCATION_HEAP_THRESHOLD
- See Also:
- Constant Field Values
-
ZMQ_HEARTBEAT_CONTEXT
public static final int ZMQ_HEARTBEAT_CONTEXT
- See Also:
- Constant Field Values
-
ZMQ_SELECTOR_PROVIDERCHOOSER
public static final int ZMQ_SELECTOR_PROVIDERCHOOSER
- See Also:
- Constant Field Values
-
ZMQ_MORE
public static final int ZMQ_MORE
- See Also:
- Constant Field Values
-
ZMQ_DONTWAIT
public static final int ZMQ_DONTWAIT
- See Also:
- Constant Field Values
-
ZMQ_SNDMORE
public static final int ZMQ_SNDMORE
- See Also:
- Constant Field Values
-
ZMQ_TCP_ACCEPT_FILTER
@Deprecated public static final int ZMQ_TCP_ACCEPT_FILTER
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_IPV4ONLY
@Deprecated public static final int ZMQ_IPV4ONLY
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_DELAY_ATTACH_ON_CONNECT
@Deprecated public static final int ZMQ_DELAY_ATTACH_ON_CONNECT
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_NOBLOCK
@Deprecated public static final int ZMQ_NOBLOCK
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_FAIL_UNROUTABLE
@Deprecated public static final int ZMQ_FAIL_UNROUTABLE
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_ROUTER_BEHAVIOR
@Deprecated public static final int ZMQ_ROUTER_BEHAVIOR
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_EVENT_CONNECTED
public static final int ZMQ_EVENT_CONNECTED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_CONNECT_DELAYED
public static final int ZMQ_EVENT_CONNECT_DELAYED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_CONNECT_RETRIED
public static final int ZMQ_EVENT_CONNECT_RETRIED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_LISTENING
public static final int ZMQ_EVENT_LISTENING
- See Also:
- Constant Field Values
-
ZMQ_EVENT_BIND_FAILED
public static final int ZMQ_EVENT_BIND_FAILED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_ACCEPTED
public static final int ZMQ_EVENT_ACCEPTED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_ACCEPT_FAILED
public static final int ZMQ_EVENT_ACCEPT_FAILED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_CLOSED
public static final int ZMQ_EVENT_CLOSED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_CLOSE_FAILED
public static final int ZMQ_EVENT_CLOSE_FAILED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_DISCONNECTED
public static final int ZMQ_EVENT_DISCONNECTED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_MONITOR_STOPPED
public static final int ZMQ_EVENT_MONITOR_STOPPED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_HANDSHAKE_PROTOCOL
public static final int ZMQ_EVENT_HANDSHAKE_PROTOCOL
- See Also:
- Constant Field Values
-
ZMQ_EVENT_ALL
public static final int ZMQ_EVENT_ALL
- See Also:
- Constant Field Values
-
ZMQ_EVENT_HANDSHAKE_FAILED_NO_DETAIL
public static final int ZMQ_EVENT_HANDSHAKE_FAILED_NO_DETAIL
- See Also:
- Constant Field Values
-
ZMQ_EVENT_HANDSHAKE_SUCCEEDED
public static final int ZMQ_EVENT_HANDSHAKE_SUCCEEDED
- See Also:
- Constant Field Values
-
ZMQ_EVENT_HANDSHAKE_FAILED_PROTOCOL
public static final int ZMQ_EVENT_HANDSHAKE_FAILED_PROTOCOL
- See Also:
- Constant Field Values
-
ZMQ_EVENT_HANDSHAKE_FAILED_AUTH
public static final int ZMQ_EVENT_HANDSHAKE_FAILED_AUTH
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_UNSPECIFIED
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_UNSPECIFIED
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_INVALID_METADATA
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_INVALID_METADATA
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH
public static final int ZMQ_PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZAP_UNSPECIFIED
public static final int ZMQ_PROTOCOL_ERROR_ZAP_UNSPECIFIED
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZAP_MALFORMED_REPLY
public static final int ZMQ_PROTOCOL_ERROR_ZAP_MALFORMED_REPLY
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID
public static final int ZMQ_PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZAP_BAD_VERSION
public static final int ZMQ_PROTOCOL_ERROR_ZAP_BAD_VERSION
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE
public static final int ZMQ_PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_ZAP_INVALID_METADATA
public static final int ZMQ_PROTOCOL_ERROR_ZAP_INVALID_METADATA
- See Also:
- Constant Field Values
-
ZMQ_PROTOCOL_ERROR_WS_UNSPECIFIED
public static final int ZMQ_PROTOCOL_ERROR_WS_UNSPECIFIED
- See Also:
- Constant Field Values
-
ZMQ_POLLIN
public static final int ZMQ_POLLIN
- See Also:
- Constant Field Values
-
ZMQ_POLLOUT
public static final int ZMQ_POLLOUT
- See Also:
- Constant Field Values
-
ZMQ_POLLERR
public static final int ZMQ_POLLERR
- See Also:
- Constant Field Values
-
ZMQ_STREAMER
@Deprecated public static final int ZMQ_STREAMER
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_FORWARDER
@Deprecated public static final int ZMQ_FORWARDER
Deprecated.- See Also:
- Constant Field Values
-
ZMQ_QUEUE
@Deprecated public static final int ZMQ_QUEUE
Deprecated.- See Also:
- Constant Field Values
-
MESSAGE_SEPARATOR
public static final byte[] MESSAGE_SEPARATOR
-
SUBSCRIPTION_ALL
public static final byte[] SUBSCRIPTION_ALL
-
CHARSET
public static final java.nio.charset.Charset CHARSET
-
PROXY_PAUSE
public static final byte[] PROXY_PAUSE
-
PROXY_RESUME
public static final byte[] PROXY_RESUME
-
PROXY_TERMINATE
public static final byte[] PROXY_TERMINATE
-
PREFER_IPV6
public static final boolean PREFER_IPV6
-
-
Method Detail
-
createContext
public static Ctx createContext()
-
checkContext
private static void checkContext(Ctx ctx)
-
destroyContext
private static void destroyContext(Ctx ctx)
-
setContextOption
public static void setContextOption(Ctx ctx, int option, int optval)
-
getContextOption
public static int getContextOption(Ctx ctx, int option)
-
init
public static Ctx init(int ioThreads)
-
term
public static void term(Ctx ctx)
-
socket
public static SocketBase socket(Ctx ctx, int type)
-
checkSocket
private static void checkSocket(SocketBase s)
-
closeZeroLinger
public static void closeZeroLinger(SocketBase s)
-
close
public static void close(SocketBase s)
-
setSocketOption
public static boolean setSocketOption(SocketBase s, int option, java.lang.Object optval)
-
getSocketOptionExt
public static java.lang.Object getSocketOptionExt(SocketBase s, int option)
-
getSocketOption
public static int getSocketOption(SocketBase s, int opt)
-
monitorSocket
public static boolean monitorSocket(SocketBase s, java.lang.String addr, int events)
-
bind
public static boolean bind(SocketBase s, java.lang.String addr)
-
connect
public static boolean connect(SocketBase s, java.lang.String addr)
-
connectPeer
public static int connectPeer(SocketBase s, java.lang.String addr)
-
disconnectPeer
public static boolean disconnectPeer(SocketBase s, int routingId)
-
unbind
public static boolean unbind(SocketBase s, java.lang.String addr)
-
disconnect
public static boolean disconnect(SocketBase s, java.lang.String addr)
-
send
public static int send(SocketBase s, java.lang.String str, int flags)
-
send
public static int send(SocketBase s, Msg msg, int flags)
-
send
public static int send(SocketBase s, byte[] buf, int flags)
-
send
public static int send(SocketBase s, byte[] buf, int len, int flags)
-
sendiov
public int sendiov(SocketBase s, byte[][] a, int count, int flags)
-
sendMsg
public static boolean sendMsg(SocketBase socket, byte[]... data)
-
sendMsg
public static int sendMsg(SocketBase s, Msg msg, int flags)
-
recv
public static Msg recv(SocketBase s, int flags)
-
recviov
public int recviov(SocketBase s, byte[][] a, int count, int flags)
-
recvMsg
public static Msg recvMsg(SocketBase s, int flags)
-
join
public static boolean join(SocketBase s, java.lang.String group)
-
leave
public static boolean leave(SocketBase s, java.lang.String group)
-
msgInit
public static Msg msgInit()
-
msgInitWithSize
public static Msg msgInitWithSize(int messageSize)
-
msgSize
public static int msgSize(Msg msg)
-
getMessageOption
public static int getMessageOption(Msg msg, int option)
-
getMessageMetadata
public static java.lang.String getMessageMetadata(Msg msg, java.lang.String property)
-
setMessageRoutingId
public boolean setMessageRoutingId(Msg msg, int routingId)
-
getMessageRoutingId
public int getMessageRoutingId(Msg msg)
-
setMessageGroup
public boolean setMessageGroup(Msg msg, java.lang.String group)
-
getMessageGroup
public java.lang.String getMessageGroup(Msg msg)
-
sleep
public static void sleep(long seconds)
-
msleep
public static void msleep(long milliseconds)
-
sleep
public static void sleep(long amount, java.util.concurrent.TimeUnit unit)
-
poll
public static int poll(java.nio.channels.Selector selector, PollItem[] items, long timeout)
Polling on items with given selector CAUTION: This could be affected by jdk epoll bug- Parameters:
selector
- Open and reuse this selector and do not forget to close when it is not used.items
-timeout
-- Returns:
- number of events
-
poll
public static int poll(java.nio.channels.Selector selector, PollItem[] items, int count, long timeout)
Polling on items with given selector CAUTION: This could be affected by jdk epoll bug- Parameters:
selector
- Open and reuse this selector and do not forget to close when it is not used.items
-count
-timeout
-- Returns:
- number of events
-
proxy
public static boolean proxy(SocketBase frontend, SocketBase backend, SocketBase capture)
-
proxy
public static boolean proxy(SocketBase frontend, SocketBase backend, SocketBase capture, SocketBase control)
-
device
public static boolean device(int device, SocketBase frontend, SocketBase backend)
-
startStopwatch
public static long startStopwatch()
-
stopStopwatch
public static long stopStopwatch(long watch)
-
makeVersion
public static int makeVersion(int major, int minor, int patch)
-
strerror
public static java.lang.String strerror(int errno)
-
-