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 SummaryConstructors Constructor Description BufferedStreamSorterEx(deltix.data.stream.MessageChannel<T> delegate, long width)BufferedStreamSorterEx(deltix.data.stream.MessageChannel<T> delegate, long width, int capacity)
 - 
Method SummaryAll 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.BufferedStreamSorterclose, flush, getDelegate, getMaxTime, getMaxViolation, getQueueSize, getWidth
 
- 
 
- 
- 
- 
Method Detail- 
getCopyMessagespublic boolean getCopyMessages() 
 - 
setCopyMessagespublic 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.
 
 - 
sendpublic 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 interface- deltix.data.stream.MessageChannel<T extends deltix.qsrv.hf.pub.InstrumentMessage>
- Overrides:
- sendin class- BufferedStreamSorter<T extends deltix.qsrv.hf.pub.InstrumentMessage>
- Parameters:
- msg- A message to buffer and eventually send down the delegate channel.
 
 
- 
 
-