- PAIR - Static variable in class org.zeromq.ZMQ
-
Flag to specify a exclusive pair of items.
- password - Variable in class org.zeromq.ZAuth.ZAPRequest
-
- peek() - Method in class org.zeromq.ZMsg
-
- peekFirst() - Method in class org.zeromq.ZMsg
-
- peekLast() - Method in class org.zeromq.ZMsg
-
- poll() - Method in class org.zeromq.ZMQ.Poller
-
Issue a poll call.
- poll() - Method in class org.zeromq.ZMsg
-
- poll(long) - Method in class org.zeromq.ZMQ.Poller
-
Issue a poll call, using the specified timeout value.
- poll(ZMQ.PollItem[], int, long) - Static method in class org.zeromq.ZMQ
-
Poll on polling items until timeout
- poll(ZMQ.PollItem[], long) - Static method in class org.zeromq.ZMQ
-
Poll on polling items until timeout
- poller() - Method in class org.zeromq.ZMQ.Context
-
Deprecated.
- poller(int) - Method in class org.zeromq.ZMQ.Context
-
Deprecated.
- Poller(int) - Constructor for class org.zeromq.ZMQ.Poller
-
Constructor
- Poller(ZMQ.Context) - Constructor for class org.zeromq.ZMQ.Poller
-
Class constructor.
- Poller(ZMQ.Context, int) - Constructor for class org.zeromq.ZMQ.Poller
-
Class constructor.
- pollerr(int) - Method in class org.zeromq.ZMQ.Poller
-
Check whether the specified element in the poll set was signalled for error.
- POLLERR - Static variable in class org.zeromq.ZMQ.Poller
-
- pollFirst() - Method in class org.zeromq.ZMsg
-
- pollin(int) - Method in class org.zeromq.ZMQ.Poller
-
Check whether the specified element in the poll set was signalled for input.
- POLLIN - Static variable in class org.zeromq.ZMQ.Poller
-
These values can be ORed to specify what we want to poll for.
- PollItem(SelectableChannel, int) - Constructor for class org.zeromq.ZMQ.PollItem
-
- PollItem(ZMQ.Socket, int) - Constructor for class org.zeromq.ZMQ.PollItem
-
- pollLast() - Method in class org.zeromq.ZMsg
-
- pollout(int) - Method in class org.zeromq.ZMQ.Poller
-
Check whether the specified element in the poll set was signalled for output.
- POLLOUT - Static variable in class org.zeromq.ZMQ.Poller
-
- pop() - Method in class org.zeromq.ZMsg
-
- popString() - Method in class org.zeromq.ZMsg
-
Pop a ZFrame and return the toString() representation of it.
- principal - Variable in class org.zeromq.ZAuth.ZAPRequest
-
- print(String) - Method in class org.zeromq.ZFrame
-
- proxy(ZMQ.Socket, ZMQ.Socket, ZMQ.Socket) - Static method in class org.zeromq.ZMQ
-
Starts the built-in 0MQ proxy in the current application thread.
- PUB - Static variable in class org.zeromq.ZMQ
-
Flag to specify a PUB socket, receiving side must be a SUB or XSUB.
- PULL - Static variable in class org.zeromq.ZMQ
-
Flag to specify the receiving part of a PUSH socket.
- push(byte[]) - Method in class org.zeromq.ZMsg
-
- push(String) - Method in class org.zeromq.ZMsg
-
- push(ZFrame) - Method in class org.zeromq.ZMsg
-
- PUSH - Static variable in class org.zeromq.ZMQ
-
Flag to specify a PUSH socket, receiving side must be a PULL.
- readyOps() - Method in class org.zeromq.ZMQ.PollItem
-
- recv() - Method in class org.zeromq.ZMQ.Socket
-
Receive a message.
- recv(byte[], int, int, int) - Method in class org.zeromq.ZMQ.Socket
-
Receive a message in to a specified buffer.
- recv(int) - Method in class org.zeromq.ZMQ.Socket
-
Receive a message.
- recv(ZMQ.Socket) - Static method in class org.zeromq.ZMQ.Event
-
Receive an event from a monitor socket.
- recv(ZMQ.Socket, int) - Static method in class org.zeromq.ZMQ.Event
-
Receive an event from a monitor socket.
- recvByteBuffer(ByteBuffer, int) - Method in class org.zeromq.ZMQ.Socket
-
Receive a message
- recvFrame(ZMQ.Socket) - Static method in class org.zeromq.ZFrame
-
Receives single frame from socket, returns the received frame object, or null if the recv was interrupted.
- recvFrame(ZMQ.Socket, int) - Static method in class org.zeromq.ZFrame
-
Receive a new frame off the socket, Returns newly-allocated frame, or null if there was no input waiting, or if
the read was interrupted.
- recvMsg(ZMQ.Socket) - Static method in class org.zeromq.ZMsg
-
Receives message from socket, returns ZMsg object or null if the recv was interrupted.
- recvMsg(ZMQ.Socket, int) - Static method in class org.zeromq.ZMsg
-
Receives message from socket, returns ZMsg object or null if the recv was interrupted.
- recvStr() - Method in class org.zeromq.ZMQ.Socket
-
Deprecated.
- recvStr(int) - Method in class org.zeromq.ZMQ.Socket
-
Deprecated.
- recvStr(int, Charset) - Method in class org.zeromq.ZMQ.Socket
-
Receive a message as a String.
- recvStr(Charset) - Method in class org.zeromq.ZMQ.Socket
-
Receive a message as a String with a given Charset.
- recvZeroCopy(ByteBuffer, int, int) - Method in class org.zeromq.ZMQ.Socket
-
Zero copy recv
- register(SelectableChannel) - Method in class org.zeromq.ZMQ.Poller
-
Register a Channel for polling on all events.
- register(SelectableChannel, int) - Method in class org.zeromq.ZMQ.Poller
-
Register a Channel for polling on the specified events.
- register(ZMQ.PollItem) - Method in class org.zeromq.ZMQ.Poller
-
Register a Channel for polling on the specified events.
- register(ZMQ.Socket) - Method in class org.zeromq.ZMQ.Poller
-
Register a Socket for polling on all events.
- register(ZMQ.Socket, int) - Method in class org.zeromq.ZMQ.Poller
-
Register a Socket for polling on the specified events.
- registerHandler(ZMQ.Socket, ZDispatcher.ZMessageHandler, ZDispatcher.ZSender) - Method in class org.zeromq.ZDispatcher
-
- registerHandler(ZMQ.Socket, ZDispatcher.ZMessageHandler, ZDispatcher.ZSender, ExecutorService) - Method in class org.zeromq.ZDispatcher
-
- remove() - Method in class org.zeromq.ZMsg
-
- remove(Object) - Method in class org.zeromq.ZMsg
-
- removeAll(Collection<?>) - Method in class org.zeromq.ZMsg
-
- removeFirst() - Method in class org.zeromq.ZMsg
-
- removeFirstOccurrence(Object) - Method in class org.zeromq.ZMsg
-
- removeLast() - Method in class org.zeromq.ZMsg
-
- removeLastOccurrence(Object) - Method in class org.zeromq.ZMsg
-
- removePoller(ZMQ.PollItem) - Method in class org.zeromq.ZLoop
-
- removeTimer(Object) - Method in class org.zeromq.ZLoop
-
- REP - Static variable in class org.zeromq.ZMQ
-
Flag to specify the receiving part of a REQ socket.
- REQ - Static variable in class org.zeromq.ZMQ
-
Flag to specify a REQ socket, receiving side must be a REP.
- reset(byte[]) - Method in class org.zeromq.ZFrame
-
Sets new contents for frame
- reset(String) - Method in class org.zeromq.ZFrame
-
Sets new contents for frame
- retainAll(Collection<?>) - Method in class org.zeromq.ZMsg
-
- REUSE - Static variable in class org.zeromq.ZFrame
-
- ROUTER - Static variable in class org.zeromq.ZMQ
-
Flag to specify ROUTER socket (aka XREP).
- run() - Method in class org.zeromq.ZMQForwarder
-
Forwarding messages.
- run() - Method in class org.zeromq.ZMQQueue
-
Queuing of requests and replies.
- run(Object[]) - Method in interface org.zeromq.ZThread.IDetachedRunnable
-
- run(Object[], ZContext, ZMQ.Socket) - Method in interface org.zeromq.ZThread.IAttachedRunnable
-
- run_poll(ZMQ.PollItem[], int, long) - Static method in class org.zeromq.ZMQ.Poller
-
Issue a poll call on the specified 0MQ items.
- save(ZMsg, DataOutputStream) - Static method in class org.zeromq.ZMsg
-
Save message to an open data output stream.
- send(byte[], int) - Method in class org.zeromq.ZMQ.Socket
-
Send a message.
- send(byte[], int, int) - Method in class org.zeromq.ZMQ.Socket
-
Send a message.
- send(byte[], int, int, int) - Method in class org.zeromq.ZMQ.Socket
-
- send(String) - Method in class org.zeromq.ZMQ.Socket
-
Send a String.
- send(String, int) - Method in class org.zeromq.ZMQ.Socket
-
Send a String.
- send(ZMQ.Socket) - Method in class org.zeromq.ZMsg
-
Send message to 0MQ socket.
- send(ZMQ.Socket, boolean) - Method in class org.zeromq.ZMsg
-
Send message to 0MQ socket, destroys contents after sending if destroy param is set to true.
- send(ZMQ.Socket, int) - Method in class org.zeromq.ZFrame
-
Method to call org.zeromq.Socket send() method.
- send(ZMsg) - Method in class org.zeromq.ZDispatcher.ZSender
-
- sendAndDestroy(ZMQ.Socket) - Method in class org.zeromq.ZFrame
-
Sends frame to socket if it contains data.
- sendAndDestroy(ZMQ.Socket, int) - Method in class org.zeromq.ZFrame
-
Sends frame to socket if it contains data.
- sendAndKeep(ZMQ.Socket) - Method in class org.zeromq.ZFrame
-
Sends frame to socket if it contains any data.
- sendAndKeep(ZMQ.Socket, int) - Method in class org.zeromq.ZFrame
-
Sends frame to socket if it contains any data.
- sendByteBuffer(ByteBuffer, int) - Method in class org.zeromq.ZMQ.Socket
-
Send a message
- sendMore(String) - Method in class org.zeromq.ZMQ.Socket
-
Send a String.
- sendZeroCopy(ByteBuffer, int, int) - Method in class org.zeromq.ZMQ.Socket
-
Perform a zero copy send.
- sequence - Variable in class org.zeromq.ZAuth.ZAPRequest
-
- setAffinity(long) - Method in class org.zeromq.ZMQ.Socket
-
Get the Affinity.
- setBacklog(long) - Method in class org.zeromq.ZMQ.Socket
-
- setBytesSockopt(int, byte[]) - Method in class org.zeromq.ZMQ.Socket
-
Set the socket option value, given as a byte array.
- setConflate(boolean) - Method in class org.zeromq.ZMQ.Socket
-
Sets whether socket should keep only last received/to be sent message in its inbound/outbound queue.
- setContext(ZMQ.Context) - Method in class org.zeromq.ZContext
-
- setGSSAPIPlainText(boolean) - Method in class org.zeromq.ZMQ.Socket
-
- setGSSAPIPrincipal(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
- setGSSAPIServer(boolean) - Method in class org.zeromq.ZMQ.Socket
-
- setGSSAPIServicePrincipal(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
- setHWM(long) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_HWM' option shall set the high water mark for the specified 'socket'.
- setIdentity(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_IDENTITY' option shall set the identity of the specified 'socket'.
- setImmediate(boolean) - Method in class org.zeromq.ZMQ.Socket
-
Sets whether socket should only queue messages to completed connections.
- setIoThreads(int) - Method in class org.zeromq.ZContext
-
- setIPv4Only(boolean) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_IPV4ONLY' option shall set the underlying native socket type.
- setLinger(int) - Method in class org.zeromq.ZContext
-
- setLinger(long) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_LINGER' option shall retrieve the period for pending outbound messages to linger in memory after
closing the socket.
- setLongSockopt(int, long) - Method in class org.zeromq.ZMQ.Socket
-
Set the socket option value, given as a long.
- setMain(boolean) - Method in class org.zeromq.ZContext
-
- setMaxMsgSize(long) - Method in class org.zeromq.ZMQ.Socket
-
- setMaxSockets(int) - Method in class org.zeromq.ZMQ.Context
-
Sets the maximum number of sockets allowed on the context
- setMulticastHops(long) - Method in class org.zeromq.ZMQ.Socket
-
Sets the time-to-live field in every multicast packet sent from this socket.
- setMulticastLoop(boolean) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_MCAST_LOOP' option shall control whether data sent via multicast transports using the specified
'socket' can also be received by the sending host via loopback.
- setPlainPassword(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
Sets the password used for the PLAIN security mechanism.
- setPlainServer(boolean) - Method in class org.zeromq.ZMQ.Socket
-
Sets if the socket is for a server using the PLAIN security mechanism.
- setPlainUsername(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
Sets the username used for the PLAIN security mechanism.
- setProbeRouter(boolean) - Method in class org.zeromq.ZMQ.Socket
-
Sets whether the socket should automatically send an empty message
when a new connection is made or accepted.
- setRate(long) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_RATE' option shall set the maximum send or receive data rate for multicast transports such as in the
man page of zmq_pgm[7] using the specified 'socket'.
- setRcvHWM(long) - Method in class org.zeromq.ZMQ.Socket
-
- setReceiveBufferSize(long) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_RCVBUF' option shall set the underlying kernel receive buffer size for the 'socket' to the specified
size in bytes.
- setReceiveTimeOut(int) - Method in class org.zeromq.ZMQ.Socket
-
Sets the timeout for receive operation on the socket.
- setReconnectIVL(long) - Method in class org.zeromq.ZMQ.Socket
-
- setReconnectIVLMax(long) - Method in class org.zeromq.ZMQ.Socket
-
- setRecoveryInterval(long) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_RECOVERY_IVL' option shall set the recovery interval for multicast transports using the specified
'socket'.
- setReqCorrelate(boolean) - Method in class org.zeromq.ZMQ.Socket
-
- setReqRelaxed(boolean) - Method in class org.zeromq.ZMQ.Socket
-
- setRouterMandatory(boolean) - Method in class org.zeromq.ZMQ.Socket
-
Sets the ROUTER socket behavior when an unroutable message is encountered.
- setSendBufferSize(long) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_SNDBUF' option shall set the underlying kernel transmit buffer size for the 'socket' to the
specified size in bytes.
- setSendTimeOut(int) - Method in class org.zeromq.ZMQ.Socket
-
Sets the timeout for send operation on the socket.
- setSndHWM(long) - Method in class org.zeromq.ZMQ.Socket
-
- setSwap(long) - Method in class org.zeromq.ZMQ.Socket
-
Get the Swap.
- setTCPKeepAlive(long) - Method in class org.zeromq.ZMQ.Socket
-
Override SO_KEEPALIVE socket option (where supported by OS) to enable keep-alive packets for a socket
connection.
- setTCPKeepAliveCount(long) - Method in class org.zeromq.ZMQ.Socket
-
Override TCP_KEEPCNT socket option (where supported by OS).
- setTCPKeepAliveIdle(long) - Method in class org.zeromq.ZMQ.Socket
-
Override TCP_KEEPCNT (or TCP_KEEPALIVE on some OS) socket option (where supported by OS).
- setTCPKeepAliveInterval(long) - Method in class org.zeromq.ZMQ.Socket
-
Override TCP_KEEPINTVL socket option (where supported by OS).
- setTimeout(long) - Method in class org.zeromq.ZMQ.Poller
-
Deprecated.
- setUp() - Method in class org.zeromq.ZLoopTest
-
- setVerbose(boolean) - Method in class org.zeromq.ZAuth
-
Enable verbose tracing of commands and activity
- setXpubVerbose(boolean) - Method in class org.zeromq.ZMQ.Socket
-
Sets the XPUB socket behavior on new subscriptions and unsubscriptions.
- setZAPDomain(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
Sets the domain for ZAP (ZMQ RFC 27) authentication.
- shadow(ZContext) - Static method in class org.zeromq.ZContext
-
Creates new shadow context.
- shutdown() - Method in class org.zeromq.ZDispatcher
-
- singleMessage() - Method in class org.zeromq.ZDispatcherTest
-
- size() - Method in class org.zeromq.ZFrame
-
Returns byte size of frame, if set, else 0
- size() - Method in class org.zeromq.ZMsg
-
- SNDMORE - Static variable in class org.zeromq.ZMQ
-
Socket flag to indicate that more message parts are coming.
- socket(int) - Method in class org.zeromq.ZMQ.Context
-
Create a new Socket within this context.
- Socket(ZMQ.Context, int) - Constructor for class org.zeromq.ZMQ.Socket
-
Class constructor.
- start() - Method in class org.zeromq.ZLoop
-
- start(ZThread.IDetachedRunnable, Object...) - Static method in class org.zeromq.ZThread
-
- STREAMER - Static variable in class org.zeromq.ZMQ
-
Flag to specify a STREAMER device.
- streq(String) - Method in class org.zeromq.ZFrame
-
String equals.
- strhex() - Method in class org.zeromq.ZFrame
-
Returns frame data as a printable hex string
- SUB - Static variable in class org.zeromq.ZMQ
-
Flag to specify the receiving part of the PUB or XPUB socket.
- subscribe(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_SUBSCRIBE' option shall establish a new message filter on a 'ZMQ_SUB' socket.
- ZAPRequest() - Constructor for class org.zeromq.ZAuth.ZAPRequest
-
- ZAuth - Class in org.zeromq
-
ZAuth takes over authentication for all incoming connections in its context.
- ZAuth(ZContext) - Constructor for class org.zeromq.ZAuth
-
Install authentication for the specified context.
- ZAuth.ZAPRequest - Class in org.zeromq
-
A small class for working with ZAP requests and replies.
- ZContext - Class in org.zeromq
-
ZContext provides a high-level ZeroMQ context management class
The ZContext class wraps java org.zeromq.Context objects, which in turn wrap native 0MQ contexts.
- ZContext() - Constructor for class org.zeromq.ZContext
-
Class Constructor
- ZContextTest - Class in org.zeromq
-
Tests high-level ZContext class
- ZContextTest() - Constructor for class org.zeromq.ZContextTest
-
- ZDispatcher - Class in org.zeromq
-
Dispatcher for ZeroMQ Sockets.
- ZDispatcher() - Constructor for class org.zeromq.ZDispatcher
-
- ZDispatcher(ExecutorService) - Constructor for class org.zeromq.ZDispatcher
-
- ZDispatcher.ZMessageHandler - Interface in org.zeromq
-
- ZDispatcher.ZSender - Class in org.zeromq
-
- ZDispatcherTest - Class in org.zeromq
-
- ZDispatcherTest() - Constructor for class org.zeromq.ZDispatcherTest
-
- ZFrame - Class in org.zeromq
-
ZFrame
The ZFrame class provides methods to send and receive single message frames across 0MQ sockets.
- ZFrame() - Constructor for class org.zeromq.ZFrame
-
Class Constructor Creates an empty frame.
- ZFrame(byte[]) - Constructor for class org.zeromq.ZFrame
-
Class Constructor Copies message data into ZFrame object
- ZFrame(String) - Constructor for class org.zeromq.ZFrame
-
Class Constructor Copies String into frame data
- ZFrameTest - Class in org.zeromq
-
Tests ZFrame class
- ZFrameTest() - Constructor for class org.zeromq.ZFrameTest
-
- ZLoop - Class in org.zeromq
-
The ZLoop class provides an event-driven reactor pattern.
- ZLoop() - Constructor for class org.zeromq.ZLoop
-
- ZLoop.IZLoopHandler - Interface in org.zeromq
-
- ZLoopTest - Class in org.zeromq
-
- ZLoopTest() - Constructor for class org.zeromq.ZLoopTest
-
- ZMQ - Class in org.zeromq
-
ZeroMQ JNI Bindings.
- ZMQ() - Constructor for class org.zeromq.ZMQ
-
- ZMQ.Context - Class in org.zeromq
-
Inner class: Context.
- ZMQ.Error - Enum in org.zeromq
-
Inner class: Error.
- ZMQ.Event - Class in org.zeromq
-
Inner class: Event.
- ZMQ.Poller - Class in org.zeromq
-
Inner class: Poller.
- ZMQ.PollItem - Class in org.zeromq
-
- ZMQ.Socket - Class in org.zeromq
-
Inner class: Socket.
- ZMQException - Exception in org.zeromq
-
ZeroMQ runtime exception.
- ZMQException(String, int) - Constructor for exception org.zeromq.ZMQException
-
- ZMQForwarder - Class in org.zeromq
-
ZeroMQ Forwarder Device implementation.
- ZMQForwarder(ZMQ.Context, ZMQ.Socket, ZMQ.Socket) - Constructor for class org.zeromq.ZMQForwarder
-
Class constructor.
- ZMQForwarderTest - Class in org.zeromq
-
- ZMQForwarderTest() - Constructor for class org.zeromq.ZMQForwarderTest
-
- ZMQQueue - Class in org.zeromq
-
ZeroMQ Queue Device implementation.
- ZMQQueue(ZMQ.Context, ZMQ.Socket, ZMQ.Socket) - Constructor for class org.zeromq.ZMQQueue
-
Class constructor.
- ZMQQueueTest - Class in org.zeromq
-
- ZMQQueueTest() - Constructor for class org.zeromq.ZMQQueueTest
-
- ZMQStreamer - Class in org.zeromq
-
ZeroMQ Streamer Device implementation.
- ZMQStreamer(ZMQ.Context, ZMQ.Socket, ZMQ.Socket) - Constructor for class org.zeromq.ZMQStreamer
-
Class constructor.
- ZMQTest - Class in org.zeromq
-
- ZMQTest() - Constructor for class org.zeromq.ZMQTest
-
- ZMsg - Class in org.zeromq
-
The ZMsg class provides methods to send and receive multipart messages across 0MQ sockets.
- ZMsg() - Constructor for class org.zeromq.ZMsg
-
Class Constructor
- ZMsgTest - Class in org.zeromq
-
- ZMsgTest() - Constructor for class org.zeromq.ZMsgTest
-
- ZSender() - Constructor for class org.zeromq.ZDispatcher.ZSender
-
- ZThread - Class in org.zeromq
-
- ZThread() - Constructor for class org.zeromq.ZThread
-
- ZThread.IAttachedRunnable - Interface in org.zeromq
-
- ZThread.IDetachedRunnable - Interface in org.zeromq
-
- ZThreadTest - Class in org.zeromq
-
- ZThreadTest() - Constructor for class org.zeromq.ZThreadTest
-