org.apache.activemq.memory.buffer
Class MessageQueue

java.lang.Object
  extended by 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
MessageQueue(MessageBuffer buffer)
           
 
Method Summary
 void add(ActiveMQMessage message)
           
 void add(MessageReference messageRef)
           
 void appendMessages(List<MessageReference> answer)
           
 void clear()
           
 int evictMessage()
           
 List<MessageReference> getList()
          Returns a copy of the list
 int getPosition()
           
 int getSize()
           
 void setPosition(int position)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

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()


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.