org.apache.activemq.memory.buffer
Class OrderBasedMessageBuffer
java.lang.Object
org.apache.activemq.memory.buffer.OrderBasedMessageBuffer
- All Implemented Interfaces:
- MessageBuffer
public class OrderBasedMessageBuffer
- extends java.lang.Object
- implements MessageBuffer
A MessageBuffer
which evicts messages in arrival order so the oldest
messages are removed first.
- Version:
- $Revision: 1.1 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
OrderBasedMessageBuffer
public OrderBasedMessageBuffer()
OrderBasedMessageBuffer
public OrderBasedMessageBuffer(int limit)
getSize
public int getSize()
- Specified by:
getSize
in interface MessageBuffer
createMessageQueue
public MessageQueue createMessageQueue()
- Creates a new message queue instance
- Specified by:
createMessageQueue
in interface MessageBuffer
onSizeChanged
public void onSizeChanged(MessageQueue queue,
int delta,
int queueSize)
- After a message queue has changed we may need to perform some evictions
- Specified by:
onSizeChanged
in interface MessageBuffer
- Parameters:
delta
- queueSize
-
clear
public void clear()
- Specified by:
clear
in interface MessageBuffer
Copyright © 2009 Apache Software Foundation. All Rights Reserved.