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