public class UnacknowledgedMessageMapImpl extends Object implements UnacknowledgedMessageMap
UnacknowledgedMessageMap.Visitor
Constructor and Description |
---|
UnacknowledgedMessageMapImpl(int prefetchLimit) |
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 deliveryTag,
boolean multiple,
Map<Long,MessageInstance> msgs) |
MessageInstance |
get(long key) |
Set<Long> |
getDeliveryTags()
Get the set of delivery tags that are outstanding.
|
MessageInstance |
remove(long deliveryTag) |
void |
remove(Map<Long,MessageInstance> msgs) |
int |
size() |
void |
visit(UnacknowledgedMessageMap.Visitor visitor) |
public UnacknowledgedMessageMapImpl(int prefetchLimit)
public void collect(long deliveryTag, boolean multiple, Map<Long,MessageInstance> msgs)
collect
in interface UnacknowledgedMessageMap
public void remove(Map<Long,MessageInstance> msgs)
public MessageInstance remove(long deliveryTag)
remove
in interface UnacknowledgedMessageMap
public void visit(UnacknowledgedMessageMap.Visitor visitor)
visit
in interface UnacknowledgedMessageMap
public void add(long deliveryTag, MessageInstance message)
add
in interface UnacknowledgedMessageMap
public Collection<MessageInstance> cancelAllMessages()
cancelAllMessages
in interface UnacknowledgedMessageMap
public int size()
size
in interface UnacknowledgedMessageMap
public void clear()
clear
in interface UnacknowledgedMessageMap
public MessageInstance get(long key)
get
in interface UnacknowledgedMessageMap
public Set<Long> getDeliveryTags()
UnacknowledgedMessageMap
getDeliveryTags
in interface UnacknowledgedMessageMap
public Collection<MessageInstance> acknowledge(long deliveryTag, boolean multiple)
acknowledge
in interface UnacknowledgedMessageMap
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.