org.apache.qpid.server.ack
Class UnacknowledgedMessageMapImpl

java.lang.Object
  extended by org.apache.qpid.server.ack.UnacknowledgedMessageMapImpl
All Implemented Interfaces:
UnacknowledgedMessageMap

public class UnacknowledgedMessageMapImpl
extends Object
implements UnacknowledgedMessageMap


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.ack.UnacknowledgedMessageMap
UnacknowledgedMessageMap.Visitor
 
Constructor Summary
UnacknowledgedMessageMapImpl(int prefetchLimit)
           
 
Method Summary
 void add(long deliveryTag, QueueEntry message)
           
 Collection<QueueEntry> cancelAllMessages()
           
 void clear()
           
 void collect(long deliveryTag, boolean multiple, Map<Long,QueueEntry> msgs)
           
 QueueEntry get(long key)
           
 Set<Long> getDeliveryTags()
          Get the set of delivery tags that are outstanding.
 QueueEntry remove(long deliveryTag)
           
 void remove(Map<Long,QueueEntry> msgs)
           
 int size()
           
 void visit(UnacknowledgedMessageMap.Visitor visitor)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UnacknowledgedMessageMapImpl

public UnacknowledgedMessageMapImpl(int prefetchLimit)
Method Detail

collect

public void collect(long deliveryTag,
                    boolean multiple,
                    Map<Long,QueueEntry> msgs)
Specified by:
collect in interface UnacknowledgedMessageMap

remove

public void remove(Map<Long,QueueEntry> msgs)
Specified by:
remove in interface UnacknowledgedMessageMap

remove

public QueueEntry remove(long deliveryTag)
Specified by:
remove in interface UnacknowledgedMessageMap

visit

public void visit(UnacknowledgedMessageMap.Visitor visitor)
           throws org.apache.qpid.AMQException
Specified by:
visit in interface UnacknowledgedMessageMap
Throws:
org.apache.qpid.AMQException

add

public void add(long deliveryTag,
                QueueEntry message)
Specified by:
add in interface UnacknowledgedMessageMap

cancelAllMessages

public Collection<QueueEntry> cancelAllMessages()
Specified by:
cancelAllMessages in interface UnacknowledgedMessageMap

size

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

clear

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

get

public QueueEntry get(long key)
Specified by:
get in interface UnacknowledgedMessageMap

getDeliveryTags

public Set<Long> getDeliveryTags()
Description copied from interface: UnacknowledgedMessageMap
Get the set of delivery tags that are outstanding.

Specified by:
getDeliveryTags in interface UnacknowledgedMessageMap
Returns:
a set of delivery tags


Licensed to the Apache Software Foundation