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

Duplication detection not working well in cluster

    XMLWordPrintable

Details

    • Bug
    • Resolution: Not a Bug
    • Undefined
    • None
    • AMQ 7.9.4.OPR.5.GA
    • None
    • False
    • None
    • False
    • User Experience
    • Hide
      • Download and unzip reproducer.zip, link attached on the first private comment
      • On unzipped folder, change variable "AMQ_HOME" on create_brokers.sh script
      • Run script, two folders are created, "master" and "slave" 
        $ ./create-brokers.sh

         

      • Start "master" and "slave" brokers on two separate terminals, they start on localhost, ports 62616 and ports 63616 respectively 
        # Terminal 1
        $ master/bin/artemis run
        
        # Terminal 2
        $ slave/bin/artemis run

         

      • On another terminal start producer
        $ cd rh_maven_test_cases/03_normal-producer_with_dup_msg_detect_hdr
        $ ./run.sh
      • On another terminal start consumer
        $ cd rh_maven_test_cases/04_normal-consumer_listener
        $ ./run.sh
      • After both producer and consumer start, go to master window and send the keys Ctrl + C. You will see the consumer gets one, or more, repeated messages as follows
        12:48:11.784 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:63a13641-3dc3-11ed-a1dd-00e099001ca0] This is text message 802 
        12:48:11.789 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:63a220a3-3dc3-11ed-a1dd-00e099001ca0] This is text message 803 
        12:48:11.796 [Thread-1 (ActiveMQ-client-global-threads)] WARN  o.a.activemq.artemis.core.client - AMQ212037: Connection failure to localhost/127.0.0.1:62616 has been detected: AMQ219015: The connection was disconnected because of server shutdown [code=DISCONNECTED] 
        12:48:11.813 [Thread-0 (org.apache.activemq.artemis.jms.client.ActiveMQConnection)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Failover event triggered :FAILURE_DETECTED 
        12:48:12.985 [Thread-0 (org.apache.activemq.artemis.jms.client.ActiveMQConnection)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Failover event triggered :FAILOVER_COMPLETED 
        12:48:12.995 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:63a220a3-3dc3-11ed-a1dd-00e099001ca0] This is text message 803 
        12:48:12.998 [Thread-1 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:645962b8-3dc3-11ed-a1dd-00e099001ca0] This is text message 804 
        12:48:13.010 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:645b5e8a-3dc3-11ed-a1dd-00e099001ca0] This is text message 805

         

       

       

       

      Show
      Download and unzip reproducer.zip, link attached on the first private comment On unzipped folder, change variable "AMQ_HOME" on create_brokers.sh script Run script, two folders are created, "master" and "slave"  $ ./create-brokers.sh   Start "master" and "slave" brokers on two separate terminals, they start on localhost, ports 62616 and ports 63616 respectively  # Terminal 1 $ master/bin/artemis run # Terminal 2 $ slave/bin/artemis run   On another terminal start producer $ cd rh_maven_test_cases/03_normal-producer_with_dup_msg_detect_hdr $ ./run.sh On another terminal start consumer $ cd rh_maven_test_cases/04_normal-consumer_listener $ ./run.sh After both producer and consumer start, go to master window and send the keys Ctrl + C. You will see the consumer gets one, or more, repeated messages as follows 12:48:11.784 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:63a13641-3dc3-11ed-a1dd-00e099001ca0] This is text message 802 12:48:11.789 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:63a220a3-3dc3-11ed-a1dd-00e099001ca0] This is text message 803 12:48:11.796 [Thread-1 (ActiveMQ-client-global-threads)] WARN  o.a.activemq.artemis.core.client - AMQ212037: Connection failure to localhost/127.0.0.1:62616 has been detected: AMQ219015: The connection was disconnected because of server shutdown [code=DISCONNECTED] 12:48:11.813 [Thread-0 (org.apache.activemq.artemis.jms.client.ActiveMQConnection)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Failover event triggered :FAILURE_DETECTED 12:48:12.985 [Thread-0 (org.apache.activemq.artemis.jms.client.ActiveMQConnection)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Failover event triggered :FAILOVER_COMPLETED 12:48:12.995 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:63a220a3-3dc3-11ed-a1dd-00e099001ca0] This is text message 803 12:48:12.998 [Thread-1 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:645962b8-3dc3-11ed-a1dd-00e099001ca0] This is text message 804 12:48:13.010 [Thread-0 (ActiveMQ-client-global-threads)] INFO  o.a.a.a.j.e.ClientSideFailoverListerExample - Got message: [ID:645b5e8a-3dc3-11ed-a1dd-00e099001ca0] This is text message 805        

    Description

      When making failover between a master and a slave, duplication detection fails on consumer application

      Attachments

        Activity

          People

            dbruscin Domenico Francesco Bruscino
            rhn-support-anarvaez Alfredo Narvaez
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: