org.apache.qpid.server.ack
Interface UnacknowledgedMessageMap

All Known Implementing Classes:
UnacknowledgedMessageMapImpl

public interface UnacknowledgedMessageMap


Nested Class Summary
static interface UnacknowledgedMessageMap.Visitor
           
 
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 deliveryTag)
           
 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)
           
 

Method Detail

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