Interface MessageEvictionStrategy
-
- All Known Implementing Classes:
MessageEvictionStrategySupport
,OldestMessageEvictionStrategy
,OldestMessageWithLowestPriorityEvictionStrategy
,UniquePropertyMessageEvictionStrategy
public interface MessageEvictionStrategy
A strategy for evicting messages from slow consumers.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description MessageReference[]
evictMessages(LinkedList messages)
Find the message reference in the given list with oldest messages at the front and newer messages at the endint
getEvictExpiredMessagesHighWatermark()
REturns the high water mark on which we will eagerly evict expired messages from RAM
-
-
-
Method Detail
-
evictMessages
MessageReference[] evictMessages(LinkedList messages) throws IOException
Find the message reference in the given list with oldest messages at the front and newer messages at the end- Returns:
- the message that has been evicted.
- Throws:
IOException
- if an exception occurs such as reading a message content (but should not ever happen as usually all the messages will be in RAM when this method is called).
-
getEvictExpiredMessagesHighWatermark
int getEvictExpiredMessagesHighWatermark()
REturns the high water mark on which we will eagerly evict expired messages from RAM
-
-