org.apache.qpid.server
Class ExtractResendAndRequeue
java.lang.Object
org.apache.qpid.server.ExtractResendAndRequeue
- All Implemented Interfaces:
- UnacknowledgedMessageMap.Visitor
public class ExtractResendAndRequeue
- extends Object
- implements UnacknowledgedMessageMap.Visitor
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ExtractResendAndRequeue
public ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap,
Map<Long,QueueEntry> msgToRequeue,
Map<Long,QueueEntry> msgToResend,
boolean requeueIfUnabletoResend,
TransactionLog txnLog)
callback
public boolean callback(long deliveryTag,
QueueEntry message)
throws org.apache.qpid.AMQException
- Specified by:
callback
in interface UnacknowledgedMessageMap.Visitor
message
- the message being iterated over @return true to stop iteration, false to continue
- Throws:
org.apache.qpid.AMQException
visitComplete
public void visitComplete()
- Specified by:
visitComplete
in interface UnacknowledgedMessageMap.Visitor
Licensed to the Apache Software Foundation