org.apache.activemq.broker.region.cursors
Class PrioritizedPendingList

java.lang.Object
  extended by org.apache.activemq.broker.region.cursors.PrioritizedPendingList
All Implemented Interfaces:
PendingList

public class PrioritizedPendingList
extends java.lang.Object
implements PendingList


Constructor Summary
PrioritizedPendingList()
           
 
Method Summary
 PendingNode addMessageFirst(MessageReference message)
           
 PendingNode addMessageLast(MessageReference message)
           
 void clear()
           
protected  OrderedPendingList getList(MessageReference msg)
           
protected  int getPriority(MessageReference message)
           
 boolean isEmpty()
           
 java.util.Iterator<MessageReference> iterator()
           
 void remove(MessageReference message)
           
 int size()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

PrioritizedPendingList

public PrioritizedPendingList()
Method Detail

addMessageFirst

public PendingNode addMessageFirst(MessageReference message)
Specified by:
addMessageFirst in interface PendingList

addMessageLast

public PendingNode addMessageLast(MessageReference message)
Specified by:
addMessageLast in interface PendingList

clear

public void clear()
Specified by:
clear in interface PendingList

isEmpty

public boolean isEmpty()
Specified by:
isEmpty in interface PendingList

iterator

public java.util.Iterator<MessageReference> iterator()
Specified by:
iterator in interface PendingList

remove

public void remove(MessageReference message)
Specified by:
remove in interface PendingList

size

public int size()
Specified by:
size in interface PendingList

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

getPriority

protected int getPriority(MessageReference message)

getList

protected OrderedPendingList getList(MessageReference msg)


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.