Package | Description |
---|---|
org.zeromq.api | |
org.zeromq.jzmq |
Modifier and Type | Class and Description |
---|---|
class |
RoutedMessage
Routed message contains route frames and payload frames.
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.addBuffer(ByteBuffer frame)
Add a frame containing bytes in the given Buffer to the end of the list.
|
Message |
Message.addByte(byte frame)
Add a frame containing a
byte to the end of the list. |
Message |
Message.addBytes(byte[] frame)
Add a frame containing the given bytes to the end of the list.
|
Message |
Message.addClobs(List<String> strings)
Add a frame containing a List of String values to the end of the list.
|
Message |
Message.addEmptyFrame()
Add an empty frame to the end of the list.
|
Message |
Message.addFrame(Message.Frame frame)
Add a frame to the end of the list.
|
Message |
Message.addFrames(List<Message.Frame> frames)
Add the given frames to the end of the list.
|
Message |
Message.addFrames(Message payload)
Add all frames from the given Message to the end of the list.
|
Message |
Message.addInt(int frame)
Add a frame containing an
int value to the end of the list. |
Message |
Message.addLong(long frame)
Add a frame containing a
long value to the end of the list. |
Message |
Message.addMap(Map<String,String> map)
Add a frame containing a Map of String pairs to the end of the list.
|
Message |
Message.addShort(short frame)
Add a frame containing a
short value to the end of the list. |
Message |
Message.addString(String frame)
Add a frame containing a String value to the end of the list.
|
Message |
Message.addStrings(List<String> strings)
Add a frame containing a List of String values to the end of the list.
|
Message |
RoutedMessage.getPayload()
Get the message portion of the routed message, which is the frames after
all routing frames.
|
Message |
Message.pushBuffer(ByteBuffer frame)
Add a frame containing bytes in the given Buffer to the beginning of the list.
|
Message |
Message.pushByte(byte frame)
Add a frame containing a
byte to the beginning of the list. |
Message |
Message.pushBytes(byte[] frame)
Add a frame containing the given bytes to the beginning of the list.
|
Message |
Message.pushClobs(List<String> strings)
Add a frame containing a List of String values to the beginning of the list.
|
Message |
Message.pushFrame(Message.Frame frame)
Add a frame to the beginning of the list.
|
Message |
Message.pushFrames(List<Message.Frame> frames)
Add frames to the beginning of the list, in reverse order, such that the
elements are in the same order as in the original List.
|
Message |
Message.pushFrames(Message payload)
Add frames to the beginning of the list, in reverse order, such that
the elements are in the same order as in the original Message.
|
Message |
Message.pushInt(int frame)
Add a frame containing an
int value to the beginning of the list. |
Message |
Message.pushLong(long frame)
Add a frame containing a
long value to the beginning of the list. |
Message |
Message.pushMap(Map<String,String> map)
Add a frame containing a Map of String pairs to the beginning of the list.
|
Message |
Message.pushShort(short frame)
Add a frame containing a
short value to the beginning of the list. |
Message |
Message.pushString(String frame)
Add a frame containing a String value to the beginning of the list.
|
Message |
Message.pushStrings(List<String> strings)
Add a frame containing a List of String values to the beginning of the list.
|
Message |
Receiver.receiveMessage()
Receive the full message (all frames) from the socket.
|
Message |
Receiver.receiveMessage(MessageFlag flag)
Receive the full message (all frames) from the socket.
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.addFrames(Message payload)
Add all frames from the given Message to the end of the list.
|
Message |
Message.pushFrames(Message payload)
Add frames to the beginning of the list, in reverse order, such that
the elements are in the same order as in the original Message.
|
boolean |
Sender.send(Message message)
Send the full message (all frames) on the socket.
|
Constructor and Description |
---|
Message(Message message)
Construct a message by cloning the given message's frames.
|
RoutedMessage(List<RoutedMessage.Route> routes,
Message message)
Takes the existing message and adds routes to the beginning of it.
|
RoutedMessage(RoutedMessage.Route route,
Message message)
Takes the existing message and adds a route to the beginning of it.
|
Modifier and Type | Method and Description |
---|---|
Message |
ManagedSocket.receiveMessage() |
Message |
ManagedSocket.receiveMessage(MessageFlag flag) |
Modifier and Type | Method and Description |
---|---|
boolean |
ManagedSocket.send(Message message) |
Copyright © 2019. All rights reserved.