Class MessageQueue
- java.lang.Object
-
- org.apache.activemq.memory.buffer.MessageQueue
-
public class MessageQueue extends Object
Allows messages to be added to the end of the buffer such that they are kept around and evicted in a FIFO manner.
-
-
Constructor Summary
Constructors Constructor Description MessageQueue(MessageBuffer buffer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(MessageReference messageRef)
void
add(ActiveMQMessage message)
void
appendMessages(List<MessageReference> answer)
void
clear()
int
evictMessage()
List<MessageReference>
getList()
Returns a copy of the listint
getPosition()
int
getSize()
void
setPosition(int position)
-
-
-
Constructor Detail
-
MessageQueue
public MessageQueue(MessageBuffer buffer)
-
-
Method Detail
-
add
public void add(MessageReference messageRef)
-
add
public void add(ActiveMQMessage message)
-
evictMessage
public int evictMessage()
-
getList
public List<MessageReference> getList()
Returns a copy of the list
-
appendMessages
public void appendMessages(List<MessageReference> answer)
-
getSize
public int getSize()
-
getPosition
public int getPosition()
-
setPosition
public void setPosition(int position)
-
clear
public void clear()
-
-