public class FIXProtocolParser extends java.lang.Object implements ProtocolParser
Constructor and Description |
---|
FIXProtocolParser(FIXProtocol messageType) |
Modifier and Type | Method and Description |
---|---|
void |
process(java.nio.ByteBuffer buffer,
int remainingBytes,
MessageHandler listener)
Processes a region of a byte buffer into messages of a specific protocol and then invokes the specified message
handler for each message parsed from the bytes.
|
public FIXProtocolParser(FIXProtocol messageType)
public void process(java.nio.ByteBuffer buffer, int remainingBytes, MessageHandler listener) throws StreamException
ProtocolParser
process
in interface ProtocolParser
buffer
- The byte buffer to be processed.remainingBytes
- The length of the byte buffer.listener
- The message handler invoked for each message.StreamException
- Thrown when the buffer contains corrupt data or data that is in an invalid format.