Uploaded image for project: 'ActiveMQ'
  1. ActiveMQ
  2. AMQ-4472

consumer.close() on transacted session does not release prefetched messages

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 5.8.0
    • Fix Version/s: 5.9.0
    • Component/s: JMS client
    • Labels:

      Description

      When using transactions an issue can arise where the consumer has messages in it's prefetch and when consumer.close() is called the consumer is not closed and does not release the messages.

      The use case is as follows:

      1) Create producer
      2) Create consumer
      3) Send message to queue
      4) Commit session
      5) Send a new message
      6) Close the consumer
      7) Start a new consumer
      8) Try to receive the message

      Test case will be attached shortly.

        Attachments

        1. amq-4472.zip
          25 kB
          Jason Sherman

          Issue Links

            Activity

              People

              • Assignee:
                chirino Hiram R. Chirino
                Reporter:
                jsherman1 Jason Sherman
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: