Uploaded image for project: 'ActiveMQ Classic'
  1. ActiveMQ Classic
  2. AMQ-2259

network of brokers - pending messages not getting forwarded

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Won't Fix
    • 5.2.0
    • None
    • Broker
    • None

    Description

      Hi ,
      Am having an issue with network of brokers where in the pending messages are not getting forwarded . Here is the scenario .

      I have two brokers configured in network AMQ1 and AMQ2. I have defined a virtual topic Virtual.A
      STEP 1) Publisher is publishing 10 messages on AMQ1 and AMQ2 has a consumer to the virtual queue Consumer.X.Virtual.A with a selector that matches half the messages (5 messages) published , and the web console correctly shows 5 pending messages.
      STEP 2) Now I bring up a consumer Consumer.X.virtual.A on AMQ1 (with out restarting the broker) , this time with a selector matching the remaining pending messages . I have left it running for a while and dint see any messages getting forwarded from AMQ2 to AMQ1 . (am not using conduit subscription and my networkTTL is set to 5 with dynamicOnly set to true)

      STEP 3) But when i restart AMQ1 , I see all messages forwarded from AMQ2 to AMQ1.
      Am I missing some configuration here ?

      Have another question on web console as well .

      After STEP 1 on AMQ1 I see Messages sent and Messages received set to 10 and on AMQ2 messages sent was 10 and messages received was 5 while pending messages were 5 .
      Why would AMQ1 show it as 10 for both receive and sent , Should i be reading it as messages received and messages forwarded.

      I greatly appreciate your response .

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              mprem74 madderla prem kumar
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: