Add a new method getQueueDepth(AMQDestionation, boolean) into AMQSession to 
allow sync message acknowledgment before sending QueueQuery command
-----------------------------------------------------------------------------------------------------------------------------------------------

                 Key: QPID-3790
                 URL: https://issues.apache.org/jira/browse/QPID-3790
             Project: Qpid
          Issue Type: New Feature
          Components: Java Client
    Affects Versions: 0.15
            Reporter: Alex Rudyy
             Fix For: 0.15


The number of existing tests fails sporadically in DUPS_OK mode by relying on 
fact that method AMQSession.getQueueDepth(AMQDestionation) returns the correct 
result.

In case of DUPS_OK, a message acknowledgment can be sent as part 
AMQSession.getQueueDepth(AMQDestionation) before sending QueueQuery command.
Currently session does not sync between sending acknowledgments(MessageAccept)  
and QueueQuery commands.

As result of it QueueQuery command results can be returned before MessageAccept 
is processed on the broker. In  this case QueueQuery results might contain 
incorrect messageCount value.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:[email protected]

Reply via email to