public class OrderBasedMessageBuffer extends Object implements MessageBuffer
MessageBuffer
which evicts messages in arrival order so the oldest
messages are removed first.Constructor and Description |
---|
OrderBasedMessageBuffer() |
OrderBasedMessageBuffer(int limit) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
MessageQueue |
createMessageQueue()
Creates a new message queue instance
|
int |
getSize() |
void |
onSizeChanged(MessageQueue queue,
int delta,
int queueSize)
After a message queue has changed we may need to perform some evictions
|
public OrderBasedMessageBuffer()
public OrderBasedMessageBuffer(int limit)
public int getSize()
getSize
in interface MessageBuffer
public MessageQueue createMessageQueue()
createMessageQueue
in interface MessageBuffer
public void onSizeChanged(MessageQueue queue, int delta, int queueSize)
onSizeChanged
in interface MessageBuffer
delta
- queueSize
- public void clear()
clear
in interface MessageBuffer
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.