A B C D E F G H I L M N O P Q R S T U V W X Z
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- add(byte[]) - Method in class org.zeromq.ZMsg
- add(String) - Method in class org.zeromq.ZMsg
- add(ZFrame) - Method in class org.zeromq.ZMsg
- addAll(Collection<? extends ZFrame>) - Method in class org.zeromq.ZMsg
- addFirst(byte[]) - Method in class org.zeromq.ZMsg
- addFirst(String) - Method in class org.zeromq.ZMsg
- addFirst(ZFrame) - Method in class org.zeromq.ZMsg
- addLast(byte[]) - Method in class org.zeromq.ZMsg
- addLast(String) - Method in class org.zeromq.ZMsg
- addLast(ZFrame) - Method in class org.zeromq.ZMsg
- addPoller(ZMQ.PollItem, ZLoop.IZLoopHandler, Object) - Method in class org.zeromq.ZLoop
- address - Variable in class org.zeromq.ZAuth.ZAPRequest
- addString(String) - Method in class org.zeromq.ZMsg
-
Add a String as a new ZFrame to the end of list
- addTimer(int, int, ZLoop.IZLoopHandler, Object) - Method in class org.zeromq.ZLoop
- allow(String) - Method in class org.zeromq.ZAuth
-
Allow (whitelist) a single IP address.
- App - Class in org.zeromq
-
Simple App to display version information about jzmq.
- App() - Constructor for class org.zeromq.App
- authenticateGSS(ZAuth.ZAPRequest) - Method in class org.zeromq.ZAuth
B
- bind(String) - Method in class org.zeromq.ZMQ.Socket
-
Bind to network interface.
- bindToRandomPort(String) - Method in class org.zeromq.ZMQ.Socket
-
Bind to network interface to a random port.
- bindToRandomPort(String, int) - Method in class org.zeromq.ZMQ.Socket
-
Bind to network interface to a random port.
- bindToRandomPort(String, int, int) - Method in class org.zeromq.ZMQ.Socket
-
Bind to network interface to a random port.
- bindToRandomPort(String, int, int, int) - Method in class org.zeromq.ZMQ.Socket
-
Bind to network interface to a random port.
C
- clear() - Method in class org.zeromq.ZMsg
- clientKey - Variable in class org.zeromq.ZAuth.ZAPRequest
- close() - Method in class org.zeromq.ZContext
- close() - Method in class org.zeromq.ZMQ.Context
- close() - Method in class org.zeromq.ZMQ.Socket
-
This is an explicit "destructor".
- close() - Method in class org.zeromq.ZMQQueue
-
Unregisters input and output sockets.
- configureGSSAPI(String) - Method in class org.zeromq.ZAuth
- configurePlain(String, String) - Method in class org.zeromq.ZAuth
-
Configure PLAIN authentication for a given domain.
- connect(String) - Method in class org.zeromq.ZMQ.Socket
-
Connect to remote application.
- construct(int) - Method in class org.zeromq.ZMQ.Context
-
Initialize the JNI interface
- construct(ZMQ.Context, int) - Method in class org.zeromq.ZMQ.Socket
-
Initialize the JNI interface
- contains(Object) - Method in class org.zeromq.ZMsg
- containsAll(Collection<?>) - Method in class org.zeromq.ZMsg
- contentSize() - Method in class org.zeromq.ZMsg
-
Return total number of bytes contained in all ZFrames in this ZMsg
- context(int) - Static method in class org.zeromq.ZMQ
-
Create a new Context.
- Context(int) - Constructor for class org.zeromq.ZMQ.Context
-
Class constructor.
- createSocket(int) - Method in class org.zeromq.ZContext
-
Creates a new managed socket within this ZContext instance.
D
- DEALER - Static variable in class org.zeromq.ZMQ
-
Flag to specify a DEALER socket (aka XREQ).
- deny(String) - Method in class org.zeromq.ZAuth
-
Deny (blacklist) a single IP address.
- descendingIterator() - Method in class org.zeromq.ZMsg
- destroy() - Method in class org.zeromq.ZAuth
-
Destructor.
- destroy() - Method in class org.zeromq.ZContext
-
Destructor.
- destroy() - Method in class org.zeromq.ZFrame
-
Destructor.
- destroy() - Method in class org.zeromq.ZLoop
- destroy() - Method in class org.zeromq.ZMQ.Context
-
Free all resources used by JNI interface.
- destroy() - Method in class org.zeromq.ZMQ.Socket
-
Free all resources used by JNI interface.
- destroy() - Method in class org.zeromq.ZMsg
-
Destructor.
- destroySocket(ZMQ.Socket) - Method in class org.zeromq.ZContext
-
Destroys managed socket within this context and remove from sockets list
- disconnect(String) - Method in class org.zeromq.ZMQ.Socket
-
Disconnect from a remote application.
- dispatcherPerformanceTest() - Method in class org.zeromq.ZDispatcherTest
- domain - Variable in class org.zeromq.ZAuth.ZAPRequest
- DONTWAIT - Static variable in class org.zeromq.ZFrame
- DONTWAIT - Static variable in class org.zeromq.ZMQ
- DOWNSTREAM - Static variable in class org.zeromq.ZMQ
-
Deprecated.
- dump(Appendable) - Method in class org.zeromq.ZMsg
-
Dump the message in human readable format.
- duplicate() - Method in class org.zeromq.ZFrame
-
Creates a new frame that duplicates an existing frame
- duplicate() - Method in class org.zeromq.ZMsg
-
Creates copy of this ZMsg.
E
- EADDRINUSE - org.zeromq.ZMQ.Error
- EADDRINUSE() - Static method in class org.zeromq.ZMQ
- EADDRNOTAVAIL - org.zeromq.ZMQ.Error
- EADDRNOTAVAIL() - Static method in class org.zeromq.ZMQ
- ECONNREFUSED - org.zeromq.ZMQ.Error
- ECONNREFUSED() - Static method in class org.zeromq.ZMQ
- EFSM - org.zeromq.ZMQ.Error
- EFSM() - Static method in class org.zeromq.ZMQ
- EHOSTUNREACH - org.zeromq.ZMQ.Error
- EHOSTUNREACH() - Static method in class org.zeromq.ZMQ
- EINPROGRESS - org.zeromq.ZMQ.Error
- EINPROGRESS() - Static method in class org.zeromq.ZMQ
- element() - Method in class org.zeromq.ZMsg
- EmbeddedLibraryTools - Class in org.zeromq
- EMTHREAD - org.zeromq.ZMQ.Error
- EMTHREAD() - Static method in class org.zeromq.ZMQ
- ENETDOWN - org.zeromq.ZMQ.Error
- ENETDOWN() - Static method in class org.zeromq.ZMQ
- ENOBUFS - org.zeromq.ZMQ.Error
- ENOBUFS() - Static method in class org.zeromq.ZMQ
- ENOCOMPATPROTO - org.zeromq.ZMQ.Error
- ENOCOMPATPROTO() - Static method in class org.zeromq.ZMQ
- ENOTSOCK - org.zeromq.ZMQ.Error
- ENOTSOCK() - Static method in class org.zeromq.ZMQ
- ENOTSUP - org.zeromq.ZMQ.Error
- ENOTSUP() - Static method in class org.zeromq.ZMQ
- EPROTONOSUPPORT - org.zeromq.ZMQ.Error
- EPROTONOSUPPORT() - Static method in class org.zeromq.ZMQ
- equals(Object) - Method in class org.zeromq.ZFrame
- equals(Object) - Method in class org.zeromq.ZMQ.PollItem
- equals(Object) - Method in class org.zeromq.ZMsg
- ETERM - org.zeromq.ZMQ.Error
- ETERM() - Static method in class org.zeromq.ZMQ
- Event(int, Object, String) - Constructor for class org.zeromq.ZMQ.Event
- EVENT_ACCEPT_FAILED - Static variable in class org.zeromq.ZMQ
-
EVENT_ACCEPT_FAILED: could not accept client connection.
- EVENT_ACCEPTED - Static variable in class org.zeromq.ZMQ
-
EVENT_ACCEPTED: connection accepted to bound interface.
- EVENT_ALL - Static variable in class org.zeromq.ZMQ
-
EVENT_ALL: all events known by the java binding.
- EVENT_BIND_FAILED - Static variable in class org.zeromq.ZMQ
-
EVENT_BIND_FAILED: socket could not bind to an address.
- EVENT_CLOSE_FAILED - Static variable in class org.zeromq.ZMQ
-
EVENT_CLOSE_FAILED: connection couldn't be closed.
- EVENT_CLOSED - Static variable in class org.zeromq.ZMQ
-
EVENT_CLOSED: connection closed.
- EVENT_CONNECT_DELAYED - Static variable in class org.zeromq.ZMQ
-
EVENT_CONNECT_DELAYED: synchronous connect failed, it's being polled.
- EVENT_CONNECT_RETRIED - Static variable in class org.zeromq.ZMQ
-
EVENT_CONNECT_RETRIED: asynchronous connect / reconnection attempt.
- EVENT_CONNECTED - Static variable in class org.zeromq.ZMQ
-
EVENT_CONNECTED: connection established.
- EVENT_DISCONNECTED - Static variable in class org.zeromq.ZMQ
-
EVENT_DISCONNECTED: broken session.
- EVENT_LISTENING - Static variable in class org.zeromq.ZMQ
-
EVENT_LISTENING: socket bound to an address, ready to accept connections.
- EVENT_MONITOR_STOPPED - Static variable in class org.zeromq.ZMQ
-
EVENT_MONITOR_STOPPED: monitor has been stopped.
F
- findByCode(int) - Static method in enum org.zeromq.ZMQ.Error
- fork(ZContext, ZThread.IAttachedRunnable, Object...) - Static method in class org.zeromq.ZThread
- FORWARDER - Static variable in class org.zeromq.ZMQ
-
Flag to specify a FORWARDER device.
G
- getAddress() - Method in class org.zeromq.ZMQ.Event
-
Get the address.
- getAffinity() - Method in class org.zeromq.ZMQ.Socket
- getBacklog() - Method in class org.zeromq.ZMQ.Socket
- getBytesSockopt(int) - Method in class org.zeromq.ZMQ.Socket
-
Get the socket option value, as a byte array.
- getCode() - Method in enum org.zeromq.ZMQ.Error
- getConflate() - Method in class org.zeromq.ZMQ.Socket
-
Indicate whether socket should keep only last received/to be sent message in its inbound/outbound queue.
- getContext() - Method in class org.zeromq.ZContext
- getCurrentPlatformIdentifier() - Static method in class org.zeromq.EmbeddedLibraryTools
- getData() - Method in class org.zeromq.ZFrame
- getEmbeddedLibraryList() - Static method in class org.zeromq.EmbeddedLibraryTools
- getErrorCode() - Method in exception org.zeromq.ZMQException
- getEvent() - Method in class org.zeromq.ZMQ.Event
- getEvents() - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_EVENTS' option shall retrieve event flags for the specified socket.
- getFD() - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_FD' option shall retrieve file descriptor associated with the 0MQ socket.
- getFirst() - Method in class org.zeromq.ZMsg
- getFullVersion() - Static method in class org.zeromq.ZMQ
- getHWM() - Method in class org.zeromq.ZMQ.Socket
- getIdentity() - Method in class org.zeromq.ZMQ.Socket
- getImmediate() - Method in class org.zeromq.ZMQ.Socket
-
Indicate whether socket should only queue messages to completed connections.
- getIoThreads() - Method in class org.zeromq.ZContext
- getIPv4Only() - Method in class org.zeromq.ZMQ.Socket
- getItem(int) - Method in class org.zeromq.ZMQ.Poller
-
Get the PollItem associated with an index.
- getLast() - Method in class org.zeromq.ZMsg
- getLinger() - Method in class org.zeromq.ZContext
- getLinger() - Method in class org.zeromq.ZMQ.Socket
- getLongSockopt(int) - Method in class org.zeromq.ZMQ.Socket
-
Get the socket option value, as a long.
- getMajorVersion() - Static method in class org.zeromq.ZMQ
- getMaxMsgSize() - Method in class org.zeromq.ZMQ.Socket
- getMaxSockets() - Method in class org.zeromq.ZMQ.Context
-
The maximum number of sockets allowed on the context
- getMinorVersion() - Static method in class org.zeromq.ZMQ
- getMulticastHops() - Method in class org.zeromq.ZMQ.Socket
- getNext() - Method in class org.zeromq.ZMQ.Poller
-
Get the index for the next position in the poll set size.
- getPatchVersion() - Static method in class org.zeromq.ZMQ
- getPlainPassword() - Method in class org.zeromq.ZMQ.Socket
- getPlainServer() - Method in class org.zeromq.ZMQ.Socket
- getPlainUsername() - Method in class org.zeromq.ZMQ.Socket
- getRate() - Method in class org.zeromq.ZMQ.Socket
- getRawSocket() - Method in class org.zeromq.ZMQ.PollItem
- getRcvHWM() - Method in class org.zeromq.ZMQ.Socket
- getReceiveBufferSize() - Method in class org.zeromq.ZMQ.Socket
- getReceiveTimeOut() - Method in class org.zeromq.ZMQ.Socket
- getReconnectIVL() - Method in class org.zeromq.ZMQ.Socket
- getReconnectIVLMax() - Method in class org.zeromq.ZMQ.Socket
- getRecoveryInterval() - Method in class org.zeromq.ZMQ.Socket
- getSendBufferSize() - Method in class org.zeromq.ZMQ.Socket
- getSendTimeOut() - Method in class org.zeromq.ZMQ.Socket
- getSize() - Method in class org.zeromq.ZMQ.Poller
-
Get the current poll set size.
- getSndHWM() - Method in class org.zeromq.ZMQ.Socket
- getSocket() - Method in class org.zeromq.ZMQ.PollItem
- getSocket(int) - Method in class org.zeromq.ZMQ.Poller
-
Get the socket associated with an index.
- getSockets() - Method in class org.zeromq.ZContext
- getSwap() - Method in class org.zeromq.ZMQ.Socket
- getTCPKeepAliveCount() - Method in class org.zeromq.ZMQ.Socket
- getTCPKeepAliveIdle() - Method in class org.zeromq.ZMQ.Socket
- getTCPKeepAliveInterval() - Method in class org.zeromq.ZMQ.Socket
- getTCPKeepAliveSetting() - Method in class org.zeromq.ZMQ.Socket
- getTimeout() - Method in class org.zeromq.ZMQ.Poller
-
Deprecated.Timeout handling has been moved to the poll() methods.
- getType() - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_TYPE option shall retrieve the socket type for the specified 'socket'.
- getValue() - Method in class org.zeromq.ZMQ.Event
- getVersionString() - Static method in class org.zeromq.ZMQ
H
- handle(ZLoop, ZMQ.PollItem, Object) - Method in interface org.zeromq.ZLoop.IZLoopHandler
- handleMessage(ZDispatcher.ZSender, ZMsg) - Method in interface org.zeromq.ZDispatcher.ZMessageHandler
- handler - Variable in class org.zeromq.ZAuth.ZAPRequest
- hasData() - Method in class org.zeromq.ZFrame
-
Convenience method to ascertain if this frame contains some message data
- hashCode() - Method in class org.zeromq.ZFrame
- hashCode() - Method in class org.zeromq.ZMsg
- hasMore() - Method in class org.zeromq.ZFrame
- hasMulticastLoop() - Method in class org.zeromq.ZMQ.Socket
- hasReceiveMore() - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_RCVMORE' option shall return a boolean value indicating if the multi-part message currently being read from the specified 'socket' has more message parts to follow.
- hasSameData(ZFrame) - Method in class org.zeromq.ZFrame
-
Returns true if both frames have byte - for byte identical data
I
- identity - Variable in class org.zeromq.ZAuth.ZAPRequest
- isEmpty() - Method in class org.zeromq.ZMsg
- isError() - Method in class org.zeromq.ZMQ.PollItem
- isMain() - Method in class org.zeromq.ZContext
- isReadable() - Method in class org.zeromq.ZMQ.PollItem
- isWritable() - Method in class org.zeromq.ZMQ.PollItem
- iterator() - Method in class org.zeromq.ZMsg
L
- load(DataInputStream) - Static method in class org.zeromq.ZMsg
-
Load / append a ZMsg from an open DataInputStream
- LOADED_EMBEDDED_LIBRARY - Static variable in class org.zeromq.EmbeddedLibraryTools
M
- main(String[]) - Static method in class org.zeromq.App
- make_version(int, int, int) - Static method in class org.zeromq.ZMQ
- makeVersion(int, int, int) - Static method in class org.zeromq.ZMQ
- mechanism - Variable in class org.zeromq.ZAuth.ZAPRequest
- monitor(String, int) - Method in class org.zeromq.ZMQ.Socket
-
Start a monitoring socket where events can be received.
- MORE - Static variable in class org.zeromq.ZFrame
N
- newStringMsg(String...) - Static method in class org.zeromq.ZMsg
-
Create a new ZMsg from one or more Strings
- NOBLOCK - Static variable in class org.zeromq.ZMQ
-
Socket flag to indicate a nonblocking send or recv mode.
O
- offer(ZFrame) - Method in class org.zeromq.ZMsg
- offerFirst(ZFrame) - Method in class org.zeromq.ZMsg
- offerLast(ZFrame) - Method in class org.zeromq.ZMsg
- org.zeromq - package org.zeromq
P
- 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.use Poller constructor
- poller(int) - Method in class org.zeromq.ZMQ.Context
-
Deprecated.use Poller constructor
- 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.
Q
R
- 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.use
ZMQ.Socket.recvStr(Charset)
instead. - recvStr(int) - Method in class org.zeromq.ZMQ.Socket
-
Deprecated.use
ZMQ.Socket.recvStr(int, Charset)
instead. - 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.
S
- 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.Timeout handling has been moved to the poll() methods.
- 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.
T
- tearDown() - Method in class org.zeromq.ZLoopTest
- term() - Method in class org.zeromq.ZMQ.Context
-
This is an explicit "destructor".
- testAddingSockets() - Method in class org.zeromq.ZContextTest
- testBindToRandomPort() - Method in class org.zeromq.ZMQTest
-
Test method for
ZMQ.Socket.bindToRandomPort(String)
. - testByteBufferRecv() - Method in class org.zeromq.ZMQTest
- testByteBufferRecvTooLarge() - Method in class org.zeromq.ZMQTest
- testByteBufferSend() - Method in class org.zeromq.ZMQTest
- testConstruction() - Method in class org.zeromq.ZContextTest
- testCopyingAndDuplicating() - Method in class org.zeromq.ZFrameTest
- testDestruction() - Method in class org.zeromq.ZContextTest
- testDetached() - Method in class org.zeromq.ZThreadTest
- testEmptyMessage() - Method in class org.zeromq.ZMsgTest
- testEventAccepted() - Method in class org.zeromq.ZMQTest
- testEventBindFailed() - Method in class org.zeromq.ZMQTest
- testEventClosed() - Method in class org.zeromq.ZMQTest
- testEventConnectDelayed() - Method in class org.zeromq.ZMQTest
- testEventConnected() - Method in class org.zeromq.ZMQTest
- testEventConnectRetried() - Method in class org.zeromq.ZMQTest
- testEventDisconnected() - Method in class org.zeromq.ZMQTest
- testEventListening() - Method in class org.zeromq.ZMQTest
- testEventMonitorStopped() - Method in class org.zeromq.ZMQTest
- testFork() - Method in class org.zeromq.ZThreadTest
- testGetVersion() - Method in class org.zeromq.ZMQTest
-
Test method for
ZMQ.getVersionString()
. - testLoadSave() - Method in class org.zeromq.ZMsgTest
- testMakeVersion() - Method in class org.zeromq.ZMQTest
-
Test method for
ZMQ.makeVersion(int, int, int)
. - testMessageEquals() - Method in class org.zeromq.ZMsgTest
- testMessageFrameManipulation() - Method in class org.zeromq.ZMsgTest
- testMessagesDispatchedToDifferentHandlersAreExecutedConcurrently() - Method in class org.zeromq.ZDispatcherTest
- testMultiPart() - Method in class org.zeromq.ZMsgTest
- testNewStringMessage() - Method in class org.zeromq.ZMsgTest
- testNoMessageAreSentAfterShutdown() - Method in class org.zeromq.ZDispatcherTest
- testPollerUnregister() - Method in class org.zeromq.ZMQTest
- testProxy() - Method in class org.zeromq.ZMQTest
- testQueue() - Method in class org.zeromq.ZMQForwarderTest
- testQueue() - Method in class org.zeromq.ZMQQueueTest
- testReceiving() - Method in class org.zeromq.ZFrameTest
- testRemovingSockets() - Method in class org.zeromq.ZContextTest
- testReqRep() - Method in class org.zeromq.ZMQTest
- testRouterMandatory() - Method in class org.zeromq.ZMQTest
-
Test method for Router Mandatory
- testSending() - Method in class org.zeromq.ZFrameTest
- testSendMoreRequestReplyOverTcp() - Method in class org.zeromq.ZMQTest
- testSetOption() - Method in class org.zeromq.ZMQTest
-
Test method for various set/get options.
- testSetXpubVerbose() - Method in class org.zeromq.ZMQTest
- testShadow() - Method in class org.zeromq.ZContextTest
- testSingleFrameMessage() - Method in class org.zeromq.ZMsgTest
- testStringFrames() - Method in class org.zeromq.ZFrameTest
- testWritingToClosedSocket() - Method in class org.zeromq.ZMQTest
- testXPUBSUB() - Method in class org.zeromq.ZMQTest
- testZeroCopyRecv() - Method in class org.zeromq.ZMQTest
- testZeroCopySend() - Method in class org.zeromq.ZMQTest
- testZFrameCreation() - Method in class org.zeromq.ZFrameTest
- testZFrameEquals() - Method in class org.zeromq.ZFrameTest
- testZLoop() - Method in class org.zeromq.ZLoopTest
- testZLoopAddTimerFromSocketHandler() - Method in class org.zeromq.ZLoopTest
- testZLoopAddTimerFromTimer() - Method in class org.zeromq.ZLoopTest
- testZLoopEndReactorFromTimer() - Method in class org.zeromq.ZLoopTest
- toArray() - Method in class org.zeromq.ZMsg
- toArray(T[]) - Method in class org.zeromq.ZMsg
- toString() - Method in class org.zeromq.ZFrame
-
Returns a human - readable representation of frame's data
- toString() - Method in exception org.zeromq.ZMQException
- toString() - Method in class org.zeromq.ZMsg
-
Convert the message to a string, for use in debugging.
U
- unbind(String) - Method in class org.zeromq.ZMQ.Socket
-
Unbind from network interface.
- unregister(SelectableChannel) - Method in class org.zeromq.ZMQ.Poller
-
Unregister a Channel for polling on the specified events.
- unregister(ZMQ.Socket) - Method in class org.zeromq.ZMQ.Poller
-
Unregister a Socket for polling on the specified events.
- unregisterHandler(ZMQ.Socket) - Method in class org.zeromq.ZDispatcher
- unsubscribe(byte[]) - Method in class org.zeromq.ZMQ.Socket
-
The 'ZMQ_UNSUBSCRIBE' option shall remove an existing message filter on a 'ZMQ_SUB' socket.
- unwrap() - Method in class org.zeromq.ZMsg
-
Pop frame off front of message, caller now owns frame.
- UPSTREAM - Static variable in class org.zeromq.ZMQ
-
Deprecated.
- username - Variable in class org.zeromq.ZAuth.ZAPRequest
V
- valueOf(String) - Static method in enum org.zeromq.ZMQ.Error
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.zeromq.ZMQ.Error
-
Returns an array containing the constants of this enum type, in the order they are declared.
- verbose(boolean) - Method in class org.zeromq.ZLoop
- version - Variable in class org.zeromq.ZAuth.ZAPRequest
- version_full() - Static method in class org.zeromq.ZMQ
- version_major() - Static method in class org.zeromq.ZMQ
- version_minor() - Static method in class org.zeromq.ZMQ
- version_patch() - Static method in class org.zeromq.ZMQ
W
- wrap(ZFrame) - Method in class org.zeromq.ZMsg
-
Push frame plus empty frame to front of message, before 1st frame.
X
- XPUB - Static variable in class org.zeromq.ZMQ
-
Flag to specify a XPUB socket, receiving side must be a SUB or XSUB.
- XREP - Static variable in class org.zeromq.ZMQ
-
Deprecated.As of release 3.0 of zeromq, replaced by
ZMQ.ROUTER
- XREQ - Static variable in class org.zeromq.ZMQ
-
Deprecated.As of release 3.0 of zeromq, replaced by
ZMQ.DEALER
- XSUB - Static variable in class org.zeromq.ZMQ
-
Flag to specify the receiving part of the PUB or XPUB socket.
Z
- 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
All Classes All Packages