Details

    • Type: Bug
    • Status: Done
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: A-MQ 7.0.0.CR1
    • Fix Version/s: AMQ 7.0.2.GA
    • Component/s: None
    • Labels:
      None
    • Environment:

      amq-broker-7.0.0.CR1-redhat-1
      amqp jms clients

    • Target Release:
    • Affects:
      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}
      

        Gliffy Diagrams

          Attachments

            Issue Links

              Activity

                People

                • Assignee:
                  ataylor Andy Taylor
                  Reporter:
                  mtoth Michal Toth
                  Tester:
                  Roman Vais
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  5 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved: