Package deltix.qsrv.hf.stream
Class BufferedStreamSorterEx<T extends deltix.qsrv.hf.pub.InstrumentMessage>
- java.lang.Object
-
- deltix.data.stream.BufferedStreamSorter<T>
-
- deltix.qsrv.hf.stream.BufferedStreamSorterEx<T>
-
- All Implemented Interfaces:
deltix.data.stream.MessageChannel<T>,deltix.util.lang.Disposable,java.io.Closeable,java.lang.AutoCloseable
public class BufferedStreamSorterEx<T extends deltix.qsrv.hf.pub.InstrumentMessage> extends BufferedStreamSorter<T>
-
-
Constructor Summary
Constructors Constructor Description BufferedStreamSorterEx(deltix.data.stream.MessageChannel<T> delegate, long width)BufferedStreamSorterEx(deltix.data.stream.MessageChannel<T> delegate, long width, int capacity)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleangetCopyMessages()voidsend(T msg)This method takes ownership of the supplied object.voidsetCopyMessages(boolean copyMessages)Determines whether this object should automatically create a copy of all messages supplied tosend(T).-
Methods inherited from class deltix.data.stream.BufferedStreamSorter
close, flush, getDelegate, getMaxTime, getMaxViolation, getQueueSize, getWidth
-
-
-
-
Method Detail
-
getCopyMessages
public boolean getCopyMessages()
-
setCopyMessages
public void setCopyMessages(boolean copyMessages)
Determines whether this object should automatically create a copy of all messages supplied tosend(T). Set this flag to false if the messages can be taken over. Set this flag to true if the messages will be re-used by the caller.- Parameters:
copyMessages- Whether this object should automatically copy all messages.
-
send
public void send(T msg)
Description copied from class:BufferedStreamSorterThis method takes ownership of the supplied object. Therefore, the supplied message object may not be reused by the caller.- Specified by:
sendin interfacedeltix.data.stream.MessageChannel<T extends deltix.qsrv.hf.pub.InstrumentMessage>- Overrides:
sendin classBufferedStreamSorter<T extends deltix.qsrv.hf.pub.InstrumentMessage>- Parameters:
msg- A message to buffer and eventually send down the delegate channel.
-
-