Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-647

purgeOnNoConsumer is not working properly

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • AMQ 7.0.2.GA
    • A-MQ 7.0.0.CR1
    • None
    • None
    • Compatibility/Configuration, User Experience

    Description

      Ocassionally broker does the proper thing and purges all messages from the queue, but sometimes (like in this case), broker leaves messages in the queue.
      This was the easiest to reporoduce directly.

      0) create a queue with defined purge-on-no-consumers & max-consumers

      java  -jar /var/dtests/node_data/clients/amqx.jar  queue --host <host>:1099 --action add --max-consumers 1 --delete-on-no-consumer True -n lala

      1) subscribe receiver to the queue (with defined timeout) and acquire 4 messages

      [0,root@r7x0_mtoth ~]$ java  -jar /var/dtests/node_data/clients/aac1.jar receiver  --log-msgs interop  --conn-username admin --conn-password admin --address lala --count 4 --broker <host>:5672 --timeout 20
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-1', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653791, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-2', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653873, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-3', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653892, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-4', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653900, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}

      2) send more messages than what receiver expects (5 msgs)

      [0,root@mt_r6x0 ~]$ java  -jar /var/dtests/node_data/clients/aac1.jar sender  --log-msgs interop --broker <host>:61616 --conn-username admin --conn-password admin --address lala --count 5   --msg-correlation-id blabla
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-1', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653791, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-2', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653873, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-3', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653892, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-4', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653900, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'id': 'bb4358aa-5820-4c52-ac3f-e7bc282b8e07:1:1:1-5', 'user-id': None, 'address': 'lala', 'subject': None, 'reply-to': None, 'correlation-id': 'blabla', 'content-type': None, 'content-encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493134653909, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': 1}, 'content': None}

      Observe number of messages in the queue 'messageCount' (is 1) & 'consumerCount' being 0.

      [0,root@mt_r6x0 ~]$ java  -jar /var/dtests/node_data/clients/amqx.jar  queue --host <host>:1099 --action properties  -n lala
{'temporary': False, 'numberOfBytesPerPage': 10485760, 'paused': False, 'messageCount': 1, 'roles': [['amq',True,True,True,True,True,True,True]], 'address-settings': {'slowConsumerThreshold': -1, 'pageCacheMaxSize': 5, 'autoCreateJmsQueues': False, 'autoDeleteJmsTopics': False, 'maxRedeliveryDelay': 0, 'pageSizeBytes': 10485760, 'addressFullMessagePolicy': 'PAGE', 'autoCreateAddress': True, 'maxSizeBytes': -1, 'expiryAddress': 'ExpiryQueue', 'redistributionDelay': -1, 'autoDeleteQueues': False, 'redeliveryMultiplier': 1, 'slowConsumerPolicy': 'NOTIFY', 'lastValueQueue': False, 'maxDeliveryAttempts': 10, 'expiryDelay': -1, 'sendToDLAOnNoRoute': False, 'autoCreateJmsTopics': True, 'DLA': 'DLQ', 'redeliveryDelay': 0, 'autoDeleteJmsQueues': False, 'slowConsumerCheckPeriod': 5, 'autoDeleteAddress': True, 'autoCreateQueues': False}, 'messagesAcknowledged': 4, 'deadLetterAddress': 'DLQ', 'durable': False, 'numberOfPages': 0, 'deliveringCount': 0, 'messagesKilled': 0, 'messagesExpired': 0, 'numberOfMessages': 1, 'expiryAddress': 'ExpiryQueue', 'bindingNames': ['lala'], 'messagesAdded': 5, 'address': 'lala', 'consumerCount': 0, 'queueNames': ['lala'], 'scheduledCount': 0, 'purgeOnNoConsumers': True, 'paging': False, 'maxConsumers': 2, 'addressSize': 553, 'firstMessageTimestamp': 0, 'name': 'lala', 'iD': 1010, 'firstMessageAge': 1493134661466}

      Attachments

        Issue Links

          is related to

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-648 JMS Openwire client is unable to send messages to queue with defined 'purgeOnNoConsumer' or queue 'filter'

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed
          relates to

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-648 JMS Openwire client is unable to send messages to queue with defined 'purgeOnNoConsumer' or queue 'filter'

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed

          Story - Created by Jira Software - do not edit or delete. Issue type for a user story. ENTMQBR-649 Unable to receive messages from queue with defined 'purgeOnNoConsumers' and default max-consumers 0

          • Minor - To be worked after urgent, high, and medium priorities are resolved. This term is chosen when the severity of the issue is low, or the complexity or effort to correct it may be higher, relatively speaking. For low priority issues, known workarounds exist or are not needed due to the trivial effort needed to address the issue.
          • Closed
          is caused by

          ARTEMIS-1277 Loading...

          Activity

            People

              rh-ee-ataylor Andy Taylor
              mtoth@redhat.com Michal Toth
              Roman Vais Roman Vais
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: