public class ExtractResendAndRequeue extends Object implements UnacknowledgedMessageMap.Visitor
Constructor and Description |
---|
ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap,
Map<Long,MessageInstance> msgToRequeue,
Map<Long,MessageInstance> msgToResend) |
Modifier and Type | Method and Description |
---|---|
boolean |
callback(long deliveryTag,
MessageInstance message) |
void |
visitComplete() |
public ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap, Map<Long,MessageInstance> msgToRequeue, Map<Long,MessageInstance> msgToResend)
public boolean callback(long deliveryTag, MessageInstance message)
callback
in interface UnacknowledgedMessageMap.Visitor
message
- the message being iterated over @return true to stop iteration, false to continuepublic void visitComplete()
visitComplete
in interface UnacknowledgedMessageMap.Visitor
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.