Class BufferedStreamSorterEx<T extends deltix.qsrv.hf.pub.InstrumentMessage>

  • 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 Detail

      • BufferedStreamSorterEx

        public BufferedStreamSorterEx​(deltix.data.stream.MessageChannel<T> delegate,
                                      long width)
      • BufferedStreamSorterEx

        public BufferedStreamSorterEx​(deltix.data.stream.MessageChannel<T> delegate,
                                      long width,
                                      int capacity)
    • 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 to send(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 interface deltix.data.stream.MessageChannel<T extends deltix.qsrv.hf.pub.InstrumentMessage>
        Overrides:
        send in class BufferedStreamSorter<T extends deltix.qsrv.hf.pub.InstrumentMessage>
        Parameters:
        msg - A message to buffer and eventually send down the delegate channel.