Interface MessageBuffer

  • All Known Implementing Classes:
    OrderBasedMessageBuffer, SizeBasedMessageBuffer

    public interface MessageBuffer
    Represents a collection of MessageQueue instances which are all bound by the same memory buffer to fix the amount of RAM used to some uppper bound.
    • Method Detail

      • getSize

        int getSize()
      • createMessageQueue

        MessageQueue createMessageQueue()
        Creates a new message queue instance
      • onSizeChanged

        void onSizeChanged​(MessageQueue queue,
                           int delta,
                           int queueSize)
        After a message queue has changed we may need to perform some evictions
        delta -
        queueSize -
      • clear

        void clear()