org.apache.activemq.memory.buffer

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 Summary

Methods

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

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

Parameters:

delta -

queueSize -

clear

void clear()