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

Qpid cpp client has problems with getting content from messages after broker has been killed

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • A-MQ 7.0.0.ER18
    • A-MQ 7.0.0.ER15
    • None

    Description

      1) subscribe receiver

      /var/dtests/node_data/clients/aac0_receiver  --timeout 60 --log-msgs dict --broker admin:admin@localhost:5672 --connection-options "{  reconnect : 'true', sasl_mechanisms : 'PLAIN', protocol : 'amqp1.0' }" --address "'test_clients_reconnect'" --count 0 # ecode:0 (exp. 0), dur.:95.34 
      

      2) start sending messages

      /var/dtests/node_data/clients/aac0_sender  --timeout 120 --log-msgs dict --broker admin:admin@localhost:5672 --connection-options "{  reconnect : 'true', sasl_mechanisms : 'PLAIN', protocol : 'amqp1.0' }" --address "'test_clients_reconnect'" --count 30 --msg-content "MSG no.%d" --msg-durable True --duration 30 # ecode:0 (exp. True), dur.:31.70 
      

      3) Repeatedly kill and start broker in the meantime with sigkill (kill -9) <broker_pid> every ~4 seconds
      4) Clients should reconnect and pick up the messages

      At 4) receiver gets disconnected and reconnecting client get a weird message content

      /var/dtests/node_data/clients/aac0_receiver  --timeout 60 --log-msgs dict --broker admin:admin@localhost:5672 --connection-options "{  reconnect : 'true', sasl_mechanisms : 'PLAIN', protocol : 'amqp1.0' }" --address "'test_clients_reconnect'" --count 0 # ecode:0 (exp. 0), dur.:95.34 
      {'redelivered': False, 'reply_to': None, 'subject': None, 'content_type': 'text/plain', 'id': None, 'user_id': None, 'correlation_id': None, 'priority': 0, 'durable': True, 'ttl': 0.000000e+00, 'size': 460, 'properties': {'x-amqp-to': 'test_clients_reconnect', 'x-opt-jms-dest': 0}, 'content': 'MSG no.12\\x00\\x00\\x01\\xffffffdd\\x00\\x00\\x00\\x0c\\x00\\x00\\x00c\\x01\\x00\\x00\\x00,t\\x00e\\x00s\\x00t\\x00_\\x00c\\x00l\\x00i\\x00e\\x00n\\x00t\\x00s\\x00_\\x00r\\x00e\\x00c\\x00o\\x00n\\x00n\\x00e\\x00c\\x00t\\x00\\x00\\x04\\xffffffff\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x06\\x00\\x00\\x00\\x12_\\x00_\\x00A\\x00M\\x00Q\\x00_\\x00C\\x00I\\x00D\\x00\\x0a\\x00\\x00\\x00H7\\x002\\x004\\x00e\\x00f\\x000\\x00a\\x008\\x00-\\x00d\\x007\\x006\\x00d\\x00-\\x004\\x000\\x008\\x000\\x00-\\x008\\x006\\x00d\\x00b\\x00-\\x003\\x008\\x00a\\x002\\x006\\x006\\x00b\\x00c\\x008\\x00c\\x007\\x001\\x00\\x00\\x00\\x004J\\x00M\\x00S\\x00_\\x00A\\x00M\\x00Q\\x00P\\x00_\\x00O\\x00R\\x00I\\x00G\\x00I\\x00N\\x00A\\x00L\\x00_\\x00E\\x00N\\x00C\\x00O\\x00D\\x00I\\x00N\\x00G\\x00\\x05\\x00\\x06\\x00\\x00\\x00\\x1eJ\\x00M\\x00S\\x00_\\x00A\\x00M\\x00Q\\x00P\\x00_\\x00H\\x00E\\x00A\\x00D\\x00E\\x00R\\x00\\x02\\xffffffff\\x00\\x00\\x00(J\\x00M\\x00S\\x00_\\x00A\\x00M\\x00Q\\x00P\\x00_\\x00C\\x00o\\x00n\\x00t\\x00e\\x00n\\x00t\\x00T\\x00y\\x00p\\x00e\\x00\\x0a\\x00\\x00\\x00\\x14t\\x00e\\x00x\\x00t\\x00/\\x00p\\x00l\\x00a\\x00i\\x00n\\x00\\x00\\x00\\x00.J\\x00M\\x00S\\x00_\\x00A\\x00M\\x00Q\\x00P\\x00_\\x00H\\x00E\\x00A\\x00D\\x00E\\x00R\\x00P\\x00R\\x00I\\x00O\\x00R\\x00I\\x00T\\x00Y\\x00\\x02\\xffffffff\\x00\\x00\\x00,J\\x00M\\x00S\\x00_\\x00A\\x00M\\x00Q\\x00P\\x00_\\x00H\\x00E\\x00A\\x00D\\x00E\\x00R\\x00D\\x00U\\x00R\\x00A\\x00B\\x00L\\x00E\\x00\\x02\\xffffffff'}
      

      Also, I have noticed that client got completely disconnected and exited without error, even though, it should continue reconnecting.

      Attachments

        Activity

          People

            cjansen@redhat.com Cliff Jansen
            mtoth@redhat.com Michal Toth
            Radim Kubis Radim Kubis
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: