Package deltix.qsrv.hf.blocks.l2

Class AbstractL2DataProcessor<COOKIE>

java.lang.Object

deltix.qsrv.hf.blocks.l2.AbstractL2DataProcessor<COOKIE>

All Implemented Interfaces:

BookHolder<COOKIE>, ConcurrentBookHolder<COOKIE>, ConcurrentL2DataProcessor<COOKIE>, L2DataProcessor<COOKIE>

Direct Known Subclasses:

LevelBasedL2DataProcessor

public abstract class AbstractL2DataProcessor<COOKIE>
extends java.lang.Object
implements L2DataProcessor<COOKIE>, ConcurrentL2DataProcessor<COOKIE>

Thread-safe

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractL2DataProcessor(L2DataProcessorConfig config)
protected	AbstractL2DataProcessor(L2DataProcessorConfig config, int capacity)

Method Summary

Modifier and Type	Method	Description
void	getBook(BookReceiver<COOKIE> receiver, java.lang.CharSequence exchange, java.lang.CharSequence symbol, deltix.qsrv.hf.pub.InstrumentType type)
Book<COOKIE>	getBook(java.lang.CharSequence exchange, java.lang.CharSequence symbol, deltix.qsrv.hf.pub.InstrumentType type)
void	getBooks(BookReceiver<COOKIE> receiver)
void	getBooks(BookReceiver<COOKIE> receiver, java.lang.CharSequence exchange)
void	getBooks(BookReceiver<COOKIE> receiver, java.lang.CharSequence symbol, deltix.qsrv.hf.pub.InstrumentType type)
L2DataProcessorConfig	getConfiguration()
void	getOrCreateBook(ModifiedBookReceiver<COOKIE> receiver, java.lang.CharSequence exchange, java.lang.CharSequence symbol, deltix.qsrv.hf.pub.InstrumentType type)
Book<COOKIE>	getOrCreateBook(java.lang.CharSequence exchange, java.lang.CharSequence symbol, deltix.qsrv.hf.pub.InstrumentType type)
protected abstract void	processL2Increment(DefaultBook<COOKIE> book, deltix.timebase.api.messages.Level2MessageInfo msg)
void	processL2Increment(ModifiedBookReceiver<COOKIE> receiver, deltix.timebase.api.messages.Level2MessageInfo msg)
Book<COOKIE>	processL2Increment(deltix.timebase.api.messages.Level2MessageInfo msg)
protected abstract void	processL2Message(DefaultBook<COOKIE> book, deltix.timebase.api.messages.L2MessageInfo msg)
void	processL2Message(ModifiedBookReceiver<COOKIE> receiver, deltix.timebase.api.messages.L2MessageInfo msg)
Book<COOKIE>	processL2Message(deltix.timebase.api.messages.L2MessageInfo msg)
protected abstract void	processL2Snapshot(DefaultBook<COOKIE> book, deltix.timebase.api.messages.L2SnapshotMessageInfo msg)
void	processL2Snapshot(ModifiedBookReceiver<COOKIE> receiver, deltix.timebase.api.messages.L2SnapshotMessageInfo msg)
Book<COOKIE>	processL2Snapshot(deltix.timebase.api.messages.L2SnapshotMessageInfo msg)
void	processMessage(ModifiedBookReceiver<COOKIE> receiver, deltix.timebase.api.messages.MarketMessageInfo msg)
Book<COOKIE>	processMessage(deltix.timebase.api.messages.MarketMessageInfo msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractL2DataProcessor

protected AbstractL2DataProcessor(L2DataProcessorConfig config)

AbstractL2DataProcessor

protected AbstractL2DataProcessor(L2DataProcessorConfig config,
                                  int capacity)

Method Detail

getConfiguration

public L2DataProcessorConfig getConfiguration()

Specified by:

getConfiguration in interface L2DataProcessor<COOKIE>

getBook

public final Book<COOKIE> getBook(java.lang.CharSequence exchange,
                                  java.lang.CharSequence symbol,
                                  deltix.qsrv.hf.pub.InstrumentType type)

Specified by:

getBook in interface BookHolder<COOKIE>

getOrCreateBook

public final Book<COOKIE> getOrCreateBook(java.lang.CharSequence exchange,
                                          java.lang.CharSequence symbol,
                                          deltix.qsrv.hf.pub.InstrumentType type)

Specified by:

getOrCreateBook in interface BookHolder<COOKIE>

getBooks

public final void getBooks(BookReceiver<COOKIE> receiver)

Specified by:

getBooks in interface ConcurrentBookHolder<COOKIE>

getBooks

public final void getBooks(BookReceiver<COOKIE> receiver,
                           java.lang.CharSequence exchange)

Specified by:

getBooks in interface ConcurrentBookHolder<COOKIE>

getBooks

public final void getBooks(BookReceiver<COOKIE> receiver,
                           java.lang.CharSequence symbol,
                           deltix.qsrv.hf.pub.InstrumentType type)

Specified by:

getBooks in interface ConcurrentBookHolder<COOKIE>

getBook

public void getBook(BookReceiver<COOKIE> receiver,
                    java.lang.CharSequence exchange,
                    java.lang.CharSequence symbol,
                    deltix.qsrv.hf.pub.InstrumentType type)

Specified by:

getBook in interface ConcurrentBookHolder<COOKIE>

getOrCreateBook

public void getOrCreateBook(ModifiedBookReceiver<COOKIE> receiver,
                            java.lang.CharSequence exchange,
                            java.lang.CharSequence symbol,
                            deltix.qsrv.hf.pub.InstrumentType type)

Specified by:

getOrCreateBook in interface ConcurrentBookHolder<COOKIE>

processMessage

public Book<COOKIE> processMessage(deltix.timebase.api.messages.MarketMessageInfo msg)

Specified by:

processMessage in interface L2DataProcessor<COOKIE>

processMessage

public void processMessage(ModifiedBookReceiver<COOKIE> receiver,
                           deltix.timebase.api.messages.MarketMessageInfo msg)

Specified by:

processMessage in interface ConcurrentL2DataProcessor<COOKIE>

processL2Snapshot

public Book<COOKIE> processL2Snapshot(deltix.timebase.api.messages.L2SnapshotMessageInfo msg)

Specified by:

processL2Snapshot in interface L2DataProcessor<COOKIE>

processL2Snapshot

public void processL2Snapshot(ModifiedBookReceiver<COOKIE> receiver,
                              deltix.timebase.api.messages.L2SnapshotMessageInfo msg)

Specified by:

processL2Snapshot in interface ConcurrentL2DataProcessor<COOKIE>

processL2Increment

public Book<COOKIE> processL2Increment(deltix.timebase.api.messages.Level2MessageInfo msg)

Specified by:

processL2Increment in interface L2DataProcessor<COOKIE>

processL2Increment

public void processL2Increment(ModifiedBookReceiver<COOKIE> receiver,
                               deltix.timebase.api.messages.Level2MessageInfo msg)

Specified by:

processL2Increment in interface ConcurrentL2DataProcessor<COOKIE>

processL2Message

public Book<COOKIE> processL2Message(deltix.timebase.api.messages.L2MessageInfo msg)

Specified by:

processL2Message in interface L2DataProcessor<COOKIE>

processL2Message

public void processL2Message(ModifiedBookReceiver<COOKIE> receiver,
                             deltix.timebase.api.messages.L2MessageInfo msg)

Specified by:

processL2Message in interface ConcurrentL2DataProcessor<COOKIE>

processL2Snapshot

protected abstract void processL2Snapshot(DefaultBook<COOKIE> book,
                                          deltix.timebase.api.messages.L2SnapshotMessageInfo msg)

processL2Increment

protected abstract void processL2Increment(DefaultBook<COOKIE> book,
                                           deltix.timebase.api.messages.Level2MessageInfo msg)

processL2Message

protected abstract void processL2Message(DefaultBook<COOKIE> book,
                                         deltix.timebase.api.messages.L2MessageInfo msg)