org.apache.qpid.server.ack
Class UnacknowledgedMessageMapImpl
java.lang.Object
org.apache.qpid.server.ack.UnacknowledgedMessageMapImpl
- All Implemented Interfaces:
- UnacknowledgedMessageMap
public class UnacknowledgedMessageMapImpl
- extends Object
- implements UnacknowledgedMessageMap
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
UnacknowledgedMessageMapImpl
public UnacknowledgedMessageMapImpl(int prefetchLimit)
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