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]