public class BinaryQTPParser extends AbstractQTPParser
AbstractQTPParser.setInput(BufferedInput)
method
immediately after construction.AbstractQTPParser
,
BinaryQTPComposer
Modifier and Type | Class and Description |
---|---|
protected static class |
BinaryQTPParser.CorruptedException
This exception is thrown to indicate that stream is corrupted.
|
protected static class |
BinaryQTPParser.CorruptedMessageException
This exception is thrown to indicate that message is corrupted.
|
Modifier and Type | Field and Description |
---|---|
protected SymbolCodec.Reader |
symbolReader |
eventTimeSequence, fieldReplacers, mixedSubscription, readEventTimeSequence, scheme, stats
Constructor and Description |
---|
BinaryQTPParser(DataScheme scheme)
Constructs parser with a specified scheme.
|
Modifier and Type | Method and Description |
---|---|
protected void |
doAfterMessageBody(com.devexperts.io.BufferedInput in,
int messageType) |
protected void |
doAfterMessageType(com.devexperts.io.BufferedInput in) |
protected void |
doBeforeMessageLength(com.devexperts.io.BufferedInput in) |
protected boolean |
isSchemeKnown() |
protected BinaryRecordDesc[] |
newRecordMap(BinaryRecordDesc[] recordMap,
int id) |
protected void |
parseImpl(com.devexperts.io.BufferedInput in,
MessageConsumer consumer) |
protected int |
readRecordId(com.devexperts.io.BufferedInput msg) |
protected long |
readSubscriptionTime(com.devexperts.io.BufferedInput msg) |
protected void |
readSymbol(com.devexperts.io.BufferedInput msg) |
protected void |
remapRecord(int id,
BinaryRecordDesc rr) |
void |
resetSession()
Resets session state for this parser.
|
protected boolean |
resyncOnCorrupted(com.devexperts.io.BufferedInput in)
Extension point to resynchronize broken/partial input stream on corrupted message.
|
protected boolean |
resyncOnParse(com.devexperts.io.BufferedInput in)
Extension point to resynchronize broken/partial input stream before each message.
|
protected BinaryRecordDesc |
wrapRecordDesc(BinaryRecordDesc desc) |
applyReadAs, getRecordBufferMode, nextRecordsMessage, parse, processPending, readAs, replaceFieldIfNeeded, setEventTimeSequence, setEventTimeSequenceIfNeeded, setFieldReplacers, setInput, setMixedSubscription, setReadEventTimeSequence, setStats
protected final SymbolCodec.Reader symbolReader
public BinaryQTPParser(DataScheme scheme)
scheme
- data scheme.protected boolean isSchemeKnown()
public void resetSession()
resetSession
in class AbstractQTPParser
protected void parseImpl(com.devexperts.io.BufferedInput in, MessageConsumer consumer) throws IOException
parseImpl
in class AbstractQTPParser
IOException
protected boolean resyncOnParse(com.devexperts.io.BufferedInput in) throws IOException
in
- the input, it is not marked.IOException
protected boolean resyncOnCorrupted(com.devexperts.io.BufferedInput in) throws IOException
in
- the input, it is marked.IOException
protected void readSymbol(com.devexperts.io.BufferedInput msg) throws IOException
IOException
protected int readRecordId(com.devexperts.io.BufferedInput msg) throws IOException
IOException
protected BinaryRecordDesc wrapRecordDesc(BinaryRecordDesc desc)
protected long readSubscriptionTime(com.devexperts.io.BufferedInput msg) throws IOException
IOException
@Nonnull protected BinaryRecordDesc[] newRecordMap(BinaryRecordDesc[] recordMap, int id)
protected void remapRecord(int id, BinaryRecordDesc rr)
protected void doBeforeMessageLength(com.devexperts.io.BufferedInput in)
protected void doAfterMessageType(com.devexperts.io.BufferedInput in)
protected void doAfterMessageBody(com.devexperts.io.BufferedInput in, int messageType)
Copyright © 2002–2025 Devexperts LLC. All rights reserved.