Package deltix.qsrv.hf.blocks

Class AbstractSorter<T extends TimeIdentity>

java.lang.Object

deltix.qsrv.hf.blocks.AbstractSorter<T>

All Implemented Interfaces:

deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>, deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

BufferedSorter, BumpUpSorter, SkipSorter

public abstract class AbstractSorter<T extends TimeIdentity>
extends java.lang.Object
implements deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>

Field Summary

Fields

Modifier and Type	Field	Description
protected T	entry
protected boolean	ignoreErrors
protected LoadingErrorListener	listener
protected java.lang.String	name
protected deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>	prev

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> channel)

Method Summary

Modifier and Type	Method	Description
void	close()
deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>	getChannel()
protected TimeIdentity	getEntry(deltix.qsrv.hf.pub.InstrumentMessage msg)
java.lang.String	getName()
protected void	onError(LoadingError e)
void	setIgnoreErrors(boolean ignoreErrors)
void	setListener(LoadingErrorListener listener)
void	setName(java.lang.String name)

Methods inherited from class java.lang.Object

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

Methods inherited from interface deltix.data.stream.MessageChannel

send

Field Detail

prev

protected final deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> prev

listener

protected LoadingErrorListener listener

ignoreErrors

protected boolean ignoreErrors

name

protected java.lang.String name

entry

protected T extends TimeIdentity entry

Constructor Detail

AbstractSorter

protected AbstractSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> channel)

Method Detail

onError

protected void onError(LoadingError e)

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

getChannel

public deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> getChannel()

setListener

public void setListener(LoadingErrorListener listener)

setIgnoreErrors

public void setIgnoreErrors(boolean ignoreErrors)

getEntry

protected TimeIdentity getEntry(deltix.qsrv.hf.pub.InstrumentMessage msg)

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface deltix.util.lang.Disposable