public interface UnacknowledgedMessageMap
Modifier and Type | Interface and Description |
---|---|
static interface |
UnacknowledgedMessageMap.Visitor |
Modifier and Type | Method and Description |
---|---|
Collection<MessageInstance> |
acknowledge(long deliveryTag,
boolean multiple) |
void |
add(long deliveryTag,
MessageInstance message) |
Collection<MessageInstance> |
cancelAllMessages() |
void |
clear() |
void |
collect(long key,
boolean multiple,
Map<Long,MessageInstance> msgs) |
MessageInstance |
get(long deliveryTag) |
Set<Long> |
getDeliveryTags()
Get the set of delivery tags that are outstanding.
|
MessageInstance |
remove(long deliveryTag) |
int |
size() |
void |
visit(UnacknowledgedMessageMap.Visitor visitor) |
void visit(UnacknowledgedMessageMap.Visitor visitor)
void add(long deliveryTag, MessageInstance message)
MessageInstance remove(long deliveryTag)
Collection<MessageInstance> cancelAllMessages()
int size()
void clear()
MessageInstance get(long deliveryTag)
Set<Long> getDeliveryTags()
Collection<MessageInstance> acknowledge(long deliveryTag, boolean multiple)
void collect(long key, boolean multiple, Map<Long,MessageInstance> msgs)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.