public class PrioritizedPendingList extends Object implements PendingList
Constructor and Description |
---|
PrioritizedPendingList() |
Modifier and Type | Method and Description |
---|---|
void |
addAll(PendingList pendingList)
Adds all the elements of the given PendingList to this PendingList.
|
PendingNode |
addMessageFirst(MessageReference message)
Adds the given message to the head of the list.
|
PendingNode |
addMessageLast(MessageReference message)
Adds the given message to the tail of the list.
|
void |
clear()
Discards all Messages currently held in the PendingList.
|
boolean |
contains(MessageReference message)
Query the PendingList to determine if the given message is contained within.
|
MessageReference |
get(MessageId messageId) |
protected OrderedPendingList |
getList(MessageReference msg) |
protected int |
getPriority(MessageReference message) |
boolean |
isEmpty()
Returns true if there are no Messages in the PendingList currently.
|
Iterator<MessageReference> |
iterator()
Returns an iterator over the pending Messages.
|
long |
messageSize() |
PendingNode |
remove(MessageReference message)
Removes the given MessageReference from the PendingList if it is
contained within.
|
int |
size()
Returns the number of MessageReferences that are awaiting dispatch.
|
String |
toString() |
Collection<MessageReference> |
values()
Returns a new Collection that contains all the MessageReferences currently
held in this PendingList.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
forEach, spliterator
public PrioritizedPendingList()
public PendingNode addMessageFirst(MessageReference message)
PendingList
addMessageFirst
in interface PendingList
message
- The MessageReference that is to be added to this list.public PendingNode addMessageLast(MessageReference message)
PendingList
addMessageLast
in interface PendingList
message
- The MessageReference that is to be added to this list.public void clear()
PendingList
clear
in interface PendingList
public boolean isEmpty()
PendingList
isEmpty
in interface PendingList
public Iterator<MessageReference> iterator()
PendingList
iterator
in interface Iterable<MessageReference>
iterator
in interface PendingList
public PendingNode remove(MessageReference message)
PendingList
remove
in interface PendingList
message
- The MessageReference that is to be removed to this list.public int size()
PendingList
size
in interface PendingList
public long messageSize()
messageSize
in interface PendingList
protected int getPriority(MessageReference message)
protected OrderedPendingList getList(MessageReference msg)
public boolean contains(MessageReference message)
PendingList
contains
in interface PendingList
message
- The Message that is the target of this query.public Collection<MessageReference> values()
PendingList
values
in interface PendingList
public void addAll(PendingList pendingList)
PendingList
addAll
in interface PendingList
pendingList
- The PendingList that is to be added to this collection.public MessageReference get(MessageId messageId)
get
in interface PendingList
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.