Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-911

Prefetched messages are not deleted from the queue when calling purge()

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Obsolete
    • Icon: Major Major
    • None
    • None
    • broker
    • None
    • Hide

      To create prefetch messages:

      1. Add to activemq.xml:

       
<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600&amp;transport.prefetch=2"/>

      2. start Fuse
      3. using hawtio, for example, send 5 messages.
      4. Consume 1 message, using consumer from https://issues.jboss.org/browse/ENTMQ-792. (Modify that consumer to consume 1 text message)

      mvn -P consume10

      5. In Hawtio select the queue 'SampleQueue1', select Delete and press "Purge queue 'SampleQueue1'" button.
      Try to browse the messages in the queue - 2 messages are left.

      If I try to consume those 2 left messages, the consumer will timeout, wthout receiving a message. After that the browse() will show no messages in the queue.

      Show
      To create prefetch messages: 1. Add to activemq.xml: <transportConnector name= "amqp" uri= "amqp: //0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600&amp;transport.prefetch=2" /> 2. start Fuse 3. using hawtio, for example, send 5 messages. 4. Consume 1 message, using consumer from https://issues.jboss.org/browse/ENTMQ-792 . (Modify that consumer to consume 1 text message) mvn -P consume10 5. In Hawtio select the queue 'SampleQueue1', select Delete and press "Purge queue 'SampleQueue1'" button. Try to browse the messages in the queue - 2 messages are left. If I try to consume those 2 left messages, the consumer will timeout, wthout receiving a message. After that the browse() will show no messages in the queue.

      Looks like regression after applying 6.1 Rollup 2 patch.
      Prefetched messages are not deleted both for persistent and non-persistent messages.

              Unassigned Unassigned
              emedvede Elena Medvedeva (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: