com.devexperts.qd.qtp

Class BinaryQTPParser

java.lang.Object

com.devexperts.qd.qtp.AbstractQTPParser

com.devexperts.qd.qtp.BinaryQTPParser

Direct Known Subclasses:

ByteArrayParser, InputStreamParser

public class BinaryQTPParser
extends AbstractQTPParser

Parses QTP messages in binary format from byte stream. The input for this parser must be configured with AbstractQTPParser.setInput(BufferedInput) method immediately after construction.

See Also:

AbstractQTPParser, BinaryQTPComposer

Nested Class Summary

Nested Classes

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.

Field Summary

Fields

Modifier and Type	Field and Description
protected SymbolCodec.Reader	symbolReader

Fields inherited from class com.devexperts.qd.qtp.AbstractQTPParser

eventTimeSequence, fieldReplacers, mixedSubscription, readEventTimeSequence, scheme, stats

Constructor Summary

Constructors

Constructor and Description
BinaryQTPParser(DataScheme scheme) Constructs parser with a specified scheme.

Method Summary

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)

Methods inherited from class com.devexperts.qd.qtp.AbstractQTPParser

applyReadAs, getRecordBufferMode, nextRecordsMessage, parse, processPending, readAs, replaceFieldIfNeeded, setEventTimeSequence, setEventTimeSequenceIfNeeded, setFieldReplacers, setInput, setMixedSubscription, setReadEventTimeSequence, setStats

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

symbolReader

protected final SymbolCodec.Reader symbolReader

Constructor Detail

BinaryQTPParser

public BinaryQTPParser(DataScheme scheme)

Constructs parser with a specified scheme.

Parameters:

scheme - data scheme.

Method Detail

isSchemeKnown

protected boolean isSchemeKnown()

resetSession

public void resetSession()

Resets session state for this parser. Resets the state of all parsed describes so far, as if this parser was just created.

Overrides:

resetSession in class AbstractQTPParser

parseImpl

protected void parseImpl(com.devexperts.io.BufferedInput in,
                         MessageConsumer consumer)
                  throws IOException

Specified by:

parseImpl in class AbstractQTPParser

Throws:

IOException

resyncOnParse

protected boolean resyncOnParse(com.devexperts.io.BufferedInput in)
                         throws IOException

Extension point to resynchronize broken/partial input stream before each message. It is invoked before attempting to parse a message.

Parameters:

in - the input, it is not marked.

Returns:

true when stream is in sync and message can be parsed.

Throws:

IOException

resyncOnCorrupted

protected boolean resyncOnCorrupted(com.devexperts.io.BufferedInput in)
                             throws IOException

Extension point to resynchronize broken/partial input stream on corrupted message. It is invoked on each failure to parse a message.

Parameters:

in - the input, it is marked.

Returns:

true when in is set to the next byte to read and stream shall be resynchronized again, false if error shall be handled.

Throws:

IOException

readSymbol

protected void readSymbol(com.devexperts.io.BufferedInput msg)
                   throws IOException

Throws:

IOException

readRecordId

protected int readRecordId(com.devexperts.io.BufferedInput msg)
                    throws IOException

Throws:

IOException

wrapRecordDesc

protected BinaryRecordDesc wrapRecordDesc(BinaryRecordDesc desc)

readSubscriptionTime

protected long readSubscriptionTime(com.devexperts.io.BufferedInput msg)
                             throws IOException

Throws:

IOException

newRecordMap

@Nonnull
protected BinaryRecordDesc[] newRecordMap(BinaryRecordDesc[] recordMap,
                                                   int id)

remapRecord

protected void remapRecord(int id,
                           BinaryRecordDesc rr)

doBeforeMessageLength

protected void doBeforeMessageLength(com.devexperts.io.BufferedInput in)

doAfterMessageType

protected void doAfterMessageType(com.devexperts.io.BufferedInput in)

doAfterMessageBody

protected void doAfterMessageBody(com.devexperts.io.BufferedInput in,
                                  int messageType)