public class MessageProxyWrapper extends Message
Header:
[Number_of_ports (2 bytes)] + [ [Port_Number (2 byte)] * Number_of_ports ]
Payload:
the complete originalMessage (prologue+header+payload)
Message.MessageType
Modifier and Type | Field and Description |
---|---|
(package private) int[] |
destPortsList |
(package private) Message |
originalMessage |
bufferHeader, bufferPayload, bufferPrologue, msgFlag, sourceIPPort, timeStamp, type
Constructor and Description |
---|
MessageProxyWrapper()
Creates an empty message to be populated using the
"fromInputStream" method.
|
MessageProxyWrapper(IPPort srcIPP,
Message msg,
int[] destPortsLst)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
private byte[] |
computeHeader()
Compute the header buffer
|
byte[] |
computePrologue()
Override the helper Message method in order to consider the originalMessage buffers
and ignore the "MessageProxyWrapper" pay load buffer.
|
boolean |
fromInputStream(java.io.InputStream is,
int size)
This method populates the "MessageXXX" instance reading data from an
input stream.
|
int[] |
getDestPortsList()
Destination ports getter
|
Message |
getOriginalMessage()
OriginalMessage getter.
|
protected void |
toOutputStream(java.io.OutputStream os)
It writes the "MessageXXX" instance to the specified stream.
|
fromInputStream, getBufferHeader, getBufferPayload, getBufferPrologue, getSourceIPPort, getTimeStamp, getType
int[] destPortsList
Message originalMessage
public MessageProxyWrapper()
private byte[] computeHeader()
public byte[] computePrologue()
computePrologue
in class Message
public boolean fromInputStream(java.io.InputStream is, int size) throws java.io.IOException
Message
fromInputStream
in class Message
java.io.IOException
public int[] getDestPortsList()
public Message getOriginalMessage()
protected void toOutputStream(java.io.OutputStream os) throws java.io.IOException
Message
toOutputStream
in class Message
java.io.IOException