public class DestinationBasedMessageList extends 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() |
List<MessageReference> |
getMessages(ActiveMQDestination destination)
Returns the current list of MessageReference objects for the given subscription
|
List<MessageReference> |
getMessages(Subscription sub) |
public DestinationBasedMessageList(int maximumSize)
public DestinationBasedMessageList(MessageBuffer buffer)
public void add(MessageReference node)
add
in interface MessageList
public List<MessageReference> getMessages(Subscription sub)
public 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–2019 The Apache Software Foundation. All rights reserved.