0 Replies Latest reply on Nov 5, 2015 10:22 PM by tea_tree2015

    Message loss on client for fuse activemq 5.5.1

    tea_tree2015

      Hello, Guys

       

      I amconfused by an activemq issue, which makes me receive duplicate message on consumer.

      I have two brokers, name as cb1 and cb2.  Producers are connecting to cb1 and cb2.  cb2 has network connector to cb1 and the following is the configuration.

      <networkConnector name="Name1" uri="static:(tcp://CB1:61617)?useExponentialBackOff=false"  duplex="true" >

                      <excludedDestinations>

                                  <queue physicalName="queue.m.>"/>

                      </excludedDestinations>

                      <staticallyIncludedDestinations>

                                  <topic physicalName="DefaultTopic"/>

                      </staticallyIncludedDestinations>

      </networkConnector>

       

      I have another broker, name as cb3, consumers are connecting to cb3.

      cb3 connects to cb1 and cb2 as follows:

      <networkConnector name="Name2" uri="static:(tcp://CB1:61617,tcp://CB2:61617)?useExponentialBackOff=false" duplex="true" >

                          <excludedDestinations>

                                  <topic physicalName="DefaultTopic"/>

                          </excludedDestinations>                                        

                          <staticallyIncludedDestinations>

                                  <queue physicalName="queue.m.>" />

                          </staticallyIncludedDestinations>

      </networkConnector>

       

      Then I found on client of cb3, it receives duplicate messages.

      The clients will not receive the message (message loss) or the active mq connection is intermittent. Check cb1 and cb2 using JConsole,  the AverageEnqueueTime of cb1 is very high > 36sec.

      And the pending message keeps on increasing.

       

      If I add "networkTTL=2" on cb3, the client will get duplicate messages.

       

        Do you have any suggestion on this issue? Thank you very much for the help!