Uploaded image for project: 'Qpid'
  1. Qpid
  2. QPID-3790

Add a new method getQueueDepth(AMQDestionation, boolean) into AMQSession to allow syncing the session before sending QueueQuery command

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.15
    • 0.15
    • JMS AMQP 0-x
    • None

    Description

      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.

      Attachments

        Activity

          People

            robbie Robbie Gemmell
            orudyy Alex Rudyy
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: