Uploaded image for project: 'JBoss Enterprise Application Platform'
  1. JBoss Enterprise Application Platform
  2. JBEAP-2531

Lost messages in XA failover test case

    XMLWordPrintable

Details

    • Bug
    • Resolution: Obsolete
    • Optional
    • None
    • 7.0.0.ER3, 7.0.0.ER6, 7.1.0.CR2
    • ActiveMQ
    • None

    Description

      Scenario:

      • Two servers in dedicated shared store HA topology.
      • Producer sends messages into the queue.
      • Consumer receives messages through the XAConnection
      • Live server is killed after execution of ServerSessionImpl#xaStart method

      Result of test: 10 messages are lost

      During normal execution journal dump looks followingly

      operation@UpdateTX;txID=2226,recordID=1504;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1506;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1508;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1510;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1512;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1514;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1516;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1518;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1520;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2226,recordID=1522;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@Prepare,txID=2226,numberOfRecords=10,extraData=AAIABQAAACQAAAAAAAAAAAAA__8KKARlAACX-1aKUKAAAAEvAAAAAAAAAAAAAAAnAAAAAAAAAAAAAP__CigEZQAAl_tWilCgAAABLk9iamVjdFN0b3Jl, xid=XidImpl (295221641 bq:0.0.0.0.0.
      0.0.0.0.0.-1.-1.10.40.4.101.0.0.-105.-5.86.-118.80.-96.0.0.1.47.0.0.0.0.0.0.0.0 formatID:131077 gtxid:0.0.0.0.0.0.0.0.0.0.-1.-1.10.40.4.101.0.0.-105.-5.86.-118.80.-96.0.0.1.46.79.98.106.101.99.116.83.116.111.114
      .101 base64:AAAAAAAAAAAAAP__CigEZQAAl_tWilCgAAABLwAAAAAAAAAAAAAAAAAAAAAAAP__CigEZQAAl_tWilCgAAABLk9iamVjdFN0b3JlBwICAA==
      operation@Commit;txID=2226,numberOfRecords=10
      operation@DeleteRecord;recordID=1504
      operation@DeleteRecord;recordID=1506
      operation@DeleteRecord;recordID=1508
      operation@DeleteRecord;recordID=1510
      operation@DeleteRecord;recordID=1512
      operation@DeleteRecord;recordID=1514
      operation@DeleteRecord;recordID=1516
      operation@DeleteRecord;recordID=1518
      operation@DeleteRecord;recordID=1520
      operation@DeleteRecord;recordID=1522
      

      During failover the journal dump says that 20 messages were committed in one transaction instead of 10. IDs of first 10 committed messages correspond to our lost ones.

      operation@UpdateTX;txID=2147483651,recordID=1524;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1526;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1528;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1530;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1532;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1534;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1536;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1538;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1540;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1542;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1544;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1546;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1548;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1550;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1552;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1554;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1556;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1558;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1560;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@UpdateTX;txID=2147483651,recordID=1562;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=7]
      operation@Prepare,txID=2147483651,numberOfRecords=20,extraData=AAIABQAAACQAAAAAAAAAAAAA__8KKARlAACX-1aKUKAAAAFAAAAAAAAAAAAAAAAnAAAAAAAAAAAAAP__CigEZQAAl_tWilCgAAABP09iamVjdFN0b3Jl, xid=XidImpl (2147046752 bq:0.0.0.0.0.0.0.0.0.0.-1.-1.10.40.4.101.0.0.-105.-5.86.-118.80.-96.0.0.1.64.0.0.0.0.0.0.0.0 formatID:131077 gtxid:0.0.0.0.0.0.0.0.0.0.-1.-1.10.40.4.101.0.0.-105.-5.86.-118.80.-96.0.0.1.63.79.98.106.101.99.116.83.116.111.114.101 base64:AAAAAAAAAAAAAP__CigEZQAAl_tWilCgAAABQAAAAAAAAAAAAAAAAAAAAAAAAP__CigEZQAAl_tWilCgAAABP09iamVjdFN0b3JlBwICAA==
      operation@Commit;txID=2147483651,numberOfRecords=20
      operation@DeleteRecord;recordID=1524
      operation@DeleteRecord;recordID=1526
      operation@DeleteRecord;recordID=1528
      operation@DeleteRecord;recordID=1530
      operation@DeleteRecord;recordID=1532
      operation@DeleteRecord;recordID=1534
      operation@DeleteRecord;recordID=1536
      operation@DeleteRecord;recordID=1538
      operation@DeleteRecord;recordID=1540
      operation@DeleteRecord;recordID=1542
      operation@DeleteRecord;recordID=1544
      operation@DeleteRecord;recordID=1546
      operation@DeleteRecord;recordID=1548
      operation@DeleteRecord;recordID=1550
      operation@DeleteRecord;recordID=1552
      operation@DeleteRecord;recordID=1554
      operation@DeleteRecord;recordID=1556
      operation@DeleteRecord;recordID=1558
      operation@DeleteRecord;recordID=1560
      operation@DeleteRecord;recordID=1562
      

      Note: Priority of the JIRA is not a blocker because this is not supported use case. Transaction Manager is setup at client side (outside EAP) to receive messages in XA transaction. It is reported because it works with EAP 6 and we want to maintain quality of product.

      Attachments

        1. journal-dump.txt
          1.44 MB
        2. test.log
          581 kB

        Activity

          People

            jondruse@redhat.com Jiri Ondrusek
            eduda_jira Erich Duda (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: