com.devexperts.qd.qtp.blob
Class BlobByteArrayParser

java.lang.Object
  extended by com.devexperts.qd.qtp.AbstractByteArrayParser
      extended by com.devexperts.qd.qtp.blob.BlobByteArrayParser

public class BlobByteArrayParser
extends AbstractByteArrayParser

The BlobByteArrayParser parses BLOB QD_HISTORY_DATA accumulated in a linear byte array buffer.

See Also:
AbstractByteArrayParser

Field Summary
 
Fields inherited from class com.devexperts.qd.qtp.AbstractByteArrayParser
in, limit, processed, readAs, recordBuffer, scheme, subscriptionBuffer
 
Constructor Summary
BlobByteArrayParser(DataRecord record, java.lang.String symbol)
          Constructs parser with a specified record and symbol.
 
Method Summary
 boolean parse(DataConsumer consumer)
           
 void parse(MessageConsumer consumer)
          Parses accumulated data and retrieve processed messages to specified MessageConsumer.
 
Methods inherited from class com.devexperts.qd.qtp.AbstractByteArrayParser
addBytes, ensureCapacity, getBuffer, getLimit, getProcessed, nextMessage, processMessage, processPending, readAs, removeBytes, replaceReadType, resetBuffer, resetSession, setLimit
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BlobByteArrayParser

public BlobByteArrayParser(DataRecord record,
                           java.lang.String symbol)
Constructs parser with a specified record and symbol.

Method Detail

parse

public void parse(MessageConsumer consumer)
Description copied from class: AbstractByteArrayParser
Parses accumulated data and retrieve processed messages to specified MessageConsumer. This is the main method in this class. It doesn't remove parsed bytes from buffer, it only updates processed value.

Specified by:
parse in class AbstractByteArrayParser
Parameters:
consumer - MessageConsumer to pass parsed messages.

parse

public boolean parse(DataConsumer consumer)