getDeliveredToConsumer() is used in place of taken() with expiration purging.
-----------------------------------------------------------------------------

                 Key: QPID-646
                 URL: https://issues.apache.org/jira/browse/QPID-646
             Project: Qpid
          Issue Type: Task
            Reporter: Martin Ritchie


Don't think this is quite right. What happends when the message is released 
right after this line. 

message will not have been delivered to the consumer any more as we now reset 
the state when releasing.

message has come from the main queue so will be undelivered/untaken

    private AMQMessage getNextMessage(Queue<AMQMessage> messages, Subscription 
sub, boolean purgeOnly) throws AMQException
CSDM:488 
            if (message.expired(_queue) && !message.getDeliveredToConsumer())


-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to