org.apache.activemq.memory.list
public class DestinationBasedMessageList extends java.lang.Object implements MessageList
MessageList
which maintains a separate message
list for each destination to reduce contention on the list and to speed up
recovery times by only recovering the interested topics.Constructor and Description |
---|
DestinationBasedMessageList(int maximumSize) |
DestinationBasedMessageList(MessageBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
add(MessageReference node) |
Message[] |
browse(ActiveMQDestination destination) |
void |
clear() |
java.util.List<MessageReference> |
getMessages(ActiveMQDestination destination)
Returns the current list of MessageReference objects for the given subscription
|
java.util.List<MessageReference> |
getMessages(Subscription sub) |
public DestinationBasedMessageList(int maximumSize)
public DestinationBasedMessageList(MessageBuffer buffer)
public void add(MessageReference node)
add
in interface MessageList
public java.util.List<MessageReference> getMessages(Subscription sub)
public java.util.List<MessageReference> getMessages(ActiveMQDestination destination)
MessageList
getMessages
in interface MessageList
public Message[] browse(ActiveMQDestination destination)
browse
in interface MessageList
public void clear()
clear
in interface MessageList
Copyright © 2005-2014. All Rights Reserved.