Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-281 Research long delays when using large number brokers in a mesh with large volume of data
  3. ENTMQ-300

network consumers get confused during high traffic volume with consumer re-connects

XMLWordPrintable

    • Icon: Sub-task Sub-task
    • Resolution: Cannot Reproduce
    • Icon: Major Major
    • JBoss A-MQ 6.1
    • JBoss A-MQ 6.0
    • None
    • None

      Opening a new subtask as it's bit different from other issues.

      In this scenario, I did the following:

      1. Start Broker 10 and populate my CMG.OUT queue with with 5000 messages.
      2. Started 8 brokers and allowed the fan out process to complete. Took ~ 11 minutes
      3. Started my consumers. There were some duplicates flying around but I saw my connections start dropping after period of time. Many consumers were left waiting for a significant number of messages. In the attached screenshot we can see store ST10272. On the left hand side we have broker 2 who says he has 571 messages and has a network consumer from broker1. On the right had side broker 1 who shows a local consumer. No messages are moving.
      4. I stopped broker2, and restarted. The consumer on broker1 moved to broker 8 as did broker2. The messages were then received and that consumer finished.

        1. broker1.out
          777 kB
          Dejan Bosanac
        2. broker1.tdump
          270 kB
          Susan Javurek
        3. broker5.tdump
          276 kB
          Susan Javurek
        4. confusednc.tiff
          463 kB
          Susan Javurek
        5. ST100030-apr29.tiff
          315 kB
          Susan Javurek
        6. ST10804.tiff
          528 kB
          Susan Javurek
        7. StoreConsumer.java
          7 kB
          Susan Javurek

              gtully@redhat.com Gary Tully
              rhn-support-sjavurek Susan Javurek
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: