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 boolean
getCopyMessages()
void
send(T msg)
This method takes ownership of the supplied object.void
setCopyMessages(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:BufferedStreamSorter
This method takes ownership of the supplied object. Therefore, the supplied message object may not be reused by the caller.- Specified by:
send
in interfacedeltix.data.stream.MessageChannel<T extends deltix.qsrv.hf.pub.InstrumentMessage>
- Overrides:
send
in classBufferedStreamSorter<T extends deltix.qsrv.hf.pub.InstrumentMessage>
- Parameters:
msg
- A message to buffer and eventually send down the delegate channel.
-
-