Class ZMQ

java.lang.Object

zmq.ZMQ

public class ZMQ
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ZMQ.Event

Field Summary

Fields

Modifier and Type	Field	Description
static final Charset	CHARSET
static final byte[]	MESSAGE_SEPARATOR
static final byte[]	PROXY_PAUSE
static final byte[]	PROXY_RESUME
static final byte[]	PROXY_TERMINATE
static final byte[]	SUBSCRIPTION_ALL
static final int	ZMQ_AFFINITY
static final int	ZMQ_BACKLOG
static final int	ZMQ_BLOCKY
static final int	ZMQ_CONFLATE
static final int	ZMQ_CONNECT_RID
static final int	ZMQ_CURVE_PUBLICKEY
static final int	ZMQ_CURVE_SECRETKEY
static final int	ZMQ_CURVE_SERVER
static final int	ZMQ_CURVE_SERVERKEY
private static final int	ZMQ_CUSTOM_OPTION
static final int	ZMQ_DEALER
static final int	ZMQ_DECODER	Deprecated.
static final int	ZMQ_DELAY_ATTACH_ON_CONNECT	Deprecated.
static final int	ZMQ_DONTWAIT
static final int	ZMQ_ENCODER	Deprecated.
static final int	ZMQ_EVENT_ACCEPT_FAILED
static final int	ZMQ_EVENT_ACCEPTED
static final int	ZMQ_EVENT_ALL
static final int	ZMQ_EVENT_BIND_FAILED
static final int	ZMQ_EVENT_CLOSE_FAILED
static final int	ZMQ_EVENT_CLOSED
static final int	ZMQ_EVENT_CONNECT_DELAYED
static final int	ZMQ_EVENT_CONNECT_RETRIED
static final int	ZMQ_EVENT_CONNECTED
static final int	ZMQ_EVENT_DISCONNECTED
static final int	ZMQ_EVENT_HANDSHAKE_PROTOCOL
static final int	ZMQ_EVENT_LISTENING
static final int	ZMQ_EVENT_MONITOR_STOPPED
static final int	ZMQ_EVENTS
static final int	ZMQ_FAIL_UNROUTABLE	Deprecated.
static final int	ZMQ_FD
static final int	ZMQ_FORWARDER	Deprecated.
static final int	ZMQ_GSSAPI_PLAINTEXT
static final int	ZMQ_GSSAPI_PRINCIPAL
static final int	ZMQ_GSSAPI_SERVER
static final int	ZMQ_GSSAPI_SERVICE_PRINCIPAL
static final int	ZMQ_HANDSHAKE_IVL
static final int	ZMQ_HEARTBEAT_CONTEXT
static final int	ZMQ_HEARTBEAT_IVL
static final int	ZMQ_HEARTBEAT_TIMEOUT
static final int	ZMQ_HEARTBEAT_TTL
static final int	ZMQ_IDENTITY
static final int	ZMQ_IMMEDIATE
static final int	ZMQ_IO_THREADS
static final int	ZMQ_IO_THREADS_DFLT
static final int	ZMQ_IPV4ONLY	Deprecated.
static final int	ZMQ_IPV6
static final int	ZMQ_LAST_ENDPOINT
static final int	ZMQ_LINGER
static final int	ZMQ_MAX_SOCKETS
static final int	ZMQ_MAX_SOCKETS_DFLT
static final int	ZMQ_MAXMSGSIZE
static final int	ZMQ_MECHANISM
static final int	ZMQ_MORE
static final int	ZMQ_MSG_ALLOCATION_HEAP_THRESHOLD
static final int	ZMQ_MSG_ALLOCATOR
static final int	ZMQ_MULTICAST_HOPS
static final int	ZMQ_NOBLOCK	Deprecated.
static final int	ZMQ_PAIR
static final int	ZMQ_PLAIN_PASSWORD
static final int	ZMQ_PLAIN_SERVER
static final int	ZMQ_PLAIN_USERNAME
static final int	ZMQ_POLLERR
static final int	ZMQ_POLLIN
static final int	ZMQ_POLLOUT
static final int	ZMQ_PROBE_ROUTER
static final int	ZMQ_PUB
static final int	ZMQ_PULL
static final int	ZMQ_PUSH
static final int	ZMQ_QUEUE	Deprecated.
static final int	ZMQ_RATE
static final int	ZMQ_RCVBUF
static final int	ZMQ_RCVHWM
static final int	ZMQ_RCVMORE
static final int	ZMQ_RCVTIMEO
static final int	ZMQ_RECONNECT_IVL
static final int	ZMQ_RECONNECT_IVL_MAX
static final int	ZMQ_RECOVERY_IVL
static final int	ZMQ_REP
static final int	ZMQ_REQ
static final int	ZMQ_REQ_CORRELATE
static final int	ZMQ_REQ_RELAXED
static final int	ZMQ_ROUTER
static final int	ZMQ_ROUTER_BEHAVIOR	Deprecated.
static final int	ZMQ_ROUTER_HANDOVER
static final int	ZMQ_ROUTER_MANDATORY
static final int	ZMQ_ROUTER_RAW
static final int	ZMQ_SELECTOR_PROVIDERCHOOSER
static final int	ZMQ_SNDBUF
static final int	ZMQ_SNDHWM
static final int	ZMQ_SNDMORE
static final int	ZMQ_SNDTIMEO
static final int	ZMQ_SOCKS_PROXY
static final int	ZMQ_STREAM
static final int	ZMQ_STREAMER	Deprecated.
static final int	ZMQ_SUB
static final int	ZMQ_SUBSCRIBE
static final int	ZMQ_TCP_ACCEPT_FILTER	Deprecated.
static final int	ZMQ_TCP_KEEPALIVE
static final int	ZMQ_TCP_KEEPALIVE_CNT
static final int	ZMQ_TCP_KEEPALIVE_IDLE
static final int	ZMQ_TCP_KEEPALIVE_INTVL
static final int	ZMQ_TOS
static final int	ZMQ_TYPE
static final int	ZMQ_UNSUBSCRIBE
static final int	ZMQ_VERSION_MAJOR
static final int	ZMQ_VERSION_MINOR
static final int	ZMQ_VERSION_PATCH
static final int	ZMQ_XPUB
static final int	ZMQ_XPUB_MANUAL
static final int	ZMQ_XPUB_NODROP
static final int	ZMQ_XPUB_VERBOSE
static final int	ZMQ_XPUB_VERBOSE_UNSUBSCRIBE	Deprecated.
static final int	ZMQ_XPUB_VERBOSER
static final int	ZMQ_XREP	Deprecated.
static final int	ZMQ_XREQ	Deprecated.
static final int	ZMQ_XSUB
static final int	ZMQ_ZAP_DOMAIN

Constructor Summary

Constructors

Constructor	Description
ZMQ()

Method Summary

Modifier and Type	Method	Description
static boolean	bind(SocketBase s, 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, 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, String addr)
static int	getContextOption(Ctx ctx, int option)
static String	getMessageMetadata(Msg msg, String property)
static int	getMessageOption(Msg msg, int option)
static int	getSocketOption(SocketBase s, int opt)
static Object	getSocketOptionExt(SocketBase s, int option)
static Ctx	init(int ioThreads)
static int	makeVersion(int major, int minor, int patch)
static boolean	monitorSocket(SocketBase s, 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(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(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, 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)
static boolean	setSocketOption(SocketBase s, int option, Object optval)
static void	sleep(long seconds)
static void	sleep(long amount, TimeUnit unit)
static SocketBase	socket(Ctx ctx, int type)
static long	startStopwatch()
static long	stopStopwatch(long watch)
static String	strerror(int errno)
static void	term(Ctx ctx)
static boolean	unbind(SocketBase s, String addr)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

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_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_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_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 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

Constructor Details

ZMQ

public ZMQ()

Method Details

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,
 Object optval)

getSocketOptionExt

public static Object getSocketOptionExt(SocketBase s,
 int option)

getSocketOption

public static int getSocketOption(SocketBase s,
 int opt)

monitorSocket

public static boolean monitorSocket(SocketBase s,
 String addr,
 int events)

bind

public static boolean bind(SocketBase s,
 String addr)

connect

public static boolean connect(SocketBase s,
 String addr)

unbind

public static boolean unbind(SocketBase s,
 String addr)

disconnect

public static boolean disconnect(SocketBase s,
 String addr)

send

public static int send(SocketBase s,
 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)

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 String getMessageMetadata(Msg msg,
 String property)

sleep

public static void sleep(long seconds)

msleep

public static void msleep(long milliseconds)

sleep

public static void sleep(long amount,
 TimeUnit unit)

poll

public static int poll(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(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 String strerror(int errno)