Package deltix.qsrv.hf.blocks

Class BumpUpSorter

java.lang.Object

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

deltix.qsrv.hf.blocks.BumpUpSorter

All Implemented Interfaces:

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

public class BumpUpSorter
extends AbstractSorter<TimeIdentity>

Provides message processing rule that bump-up out-of-sequence messages.

Field Summary

Fields inherited from class deltix.qsrv.hf.blocks.AbstractSorter

entry, ignoreErrors, listener, name, prev

Constructor Summary

Constructors

Constructor	Description
BumpUpSorter(TimeIdentity id, deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> channel, long maxDiscrepancy)

Method Summary

Modifier and Type	Method	Description
void	send(deltix.qsrv.hf.pub.InstrumentMessage msg)

Methods inherited from class deltix.qsrv.hf.blocks.AbstractSorter

close, getChannel, getEntry, getName, onError, setIgnoreErrors, setListener, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

BumpUpSorter

public BumpUpSorter(TimeIdentity id,
                    deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> channel,
                    long maxDiscrepancy)

Method Detail

send

public void send(deltix.qsrv.hf.pub.InstrumentMessage msg)