Package | Description |
---|---|
org.apache.activemq.memory.buffer |
Modifier and Type | Method and Description |
---|---|
MessageQueue |
MessageBuffer.createMessageQueue()
Creates a new message queue instance
|
MessageQueue |
SizeBasedMessageBuffer.createMessageQueue()
Creates a new message queue instance
|
MessageQueue |
OrderBasedMessageBuffer.createMessageQueue()
Creates a new message queue instance
|
Modifier and Type | Method and Description |
---|---|
protected void |
SizeBasedMessageBuffer.bubbleDown(MessageQueue biggest,
int position) |
protected void |
SizeBasedMessageBuffer.bubbleUp(MessageQueue queue,
int queueSize) |
void |
MessageBuffer.onSizeChanged(MessageQueue queue,
int delta,
int queueSize)
After a message queue has changed we may need to perform some evictions
|
void |
SizeBasedMessageBuffer.onSizeChanged(MessageQueue queue,
int delta,
int queueSize)
After a message queue has changed we may need to perform some evictions
|
void |
OrderBasedMessageBuffer.onSizeChanged(MessageQueue queue,
int delta,
int queueSize)
After a message queue has changed we may need to perform some evictions
|
protected void |
SizeBasedMessageBuffer.swap(int firstPosition,
MessageQueue first,
int secondPosition,
MessageQueue second) |
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.