org.apache.qpid.server.ack
Interface UnacknowledgedMessageMap
- All Known Implementing Classes:
- UnacknowledgedMessageMapImpl
public interface UnacknowledgedMessageMap
visit
void visit(UnacknowledgedMessageMap.Visitor visitor)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
add
void add(long deliveryTag,
QueueEntry message)
collect
void collect(long deliveryTag,
boolean multiple,
Map<Long,QueueEntry> msgs)
remove
void remove(Map<Long,QueueEntry> msgs)
remove
QueueEntry remove(long deliveryTag)
cancelAllMessages
Collection<QueueEntry> cancelAllMessages()
size
int size()
clear
void clear()
get
QueueEntry get(long deliveryTag)
getDeliveryTags
Set<Long> getDeliveryTags()
- Get the set of delivery tags that are outstanding.
- Returns:
- a set of delivery tags
Licensed to the Apache Software Foundation