public class SimpleMessageList extends Object implements MessageList
MessageList
where there is a single, fixed size
list that all messages are added to for simplicity. Though this will lead to
possibly slow recovery times as many more messages than is necessary will
have to be iterated through for each subscription.Constructor and Description |
---|
SimpleMessageList() |
SimpleMessageList(int maximumSize) |
Modifier and Type | Method and Description |
---|---|
void |
add(MessageReference node) |
Message[] |
browse(ActiveMQDestination destination) |
void |
clear() |
List<MessageReference> |
getList()
Returns a copy of the list
|
List<MessageReference> |
getMessages(ActiveMQDestination destination)
Returns the current list of MessageReference objects for the given subscription
|
int |
getSize() |
public SimpleMessageList()
public SimpleMessageList(int maximumSize)
public void add(MessageReference node)
add
in interface MessageList
public List<MessageReference> getMessages(ActiveMQDestination destination)
MessageList
getMessages
in interface MessageList
public Message[] browse(ActiveMQDestination destination)
browse
in interface MessageList
public List<MessageReference> getList()
public int getSize()
public void clear()
clear
in interface MessageList
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.