You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Martin Ritchie (JIRA)" <qp...@incubator.apache.org> on 2007/10/17 18:52:50 UTC
[jira] Created: (QPID-646) getDeliveredToConsumer() is used in
place of taken() with expiration purging.
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.
[jira] Resolved: (QPID-646) getDeliveredToConsumer() is used in
place of taken() with expiration purging.
Posted by "Martin Ritchie (JIRA)" <qp...@incubator.apache.org>.
[ https://issues.apache.org/jira/browse/QPID-646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martin Ritchie resolved QPID-646.
---------------------------------
Resolution: Fixed
Fix Version/s: M2.1
Assignee: Martin Ritchie
Usage has been removed from the broker.
> 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
> Assignee: Martin Ritchie
> Fix For: M2.1
>
>
> 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.