org.apache.qpid.server
Class ExtractResendAndRequeue

java.lang.Object
  extended by org.apache.qpid.server.ExtractResendAndRequeue
All Implemented Interfaces:
UnacknowledgedMessageMap.Visitor

public class ExtractResendAndRequeue
extends Object
implements UnacknowledgedMessageMap.Visitor


Constructor Summary
ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap, Map<Long,QueueEntry> msgToRequeue, Map<Long,QueueEntry> msgToResend, boolean requeueIfUnabletoResend, TransactionLog txnLog)
           
 
Method Summary
 boolean callback(long deliveryTag, QueueEntry message)
           
 void visitComplete()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ExtractResendAndRequeue

public ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap,
                               Map<Long,QueueEntry> msgToRequeue,
                               Map<Long,QueueEntry> msgToResend,
                               boolean requeueIfUnabletoResend,
                               TransactionLog txnLog)
Method Detail

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