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

Broker Does Not Redistribute Existing Messages

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • None
    • AMQ 7.0.3.GA
    • clustering
    • Hide
      1. copy attached QueueMessageRedistributionExample.java file into the following place 
        amq-broker-7.0.3/examples/features/clustered/queue-message-redistribution/src/main/java/org/apache/activemq/artemis/jms/example/QueueMessageRedistributionExample.java
      2. move to amq-broker-7.0.3/examples/features/clustered/queue-message-redistribution
      3. mvn clean
      4. mvn verify
      Show
      copy attached QueueMessageRedistributionExample.java file into the following place amq-broker-7.0.3/examples/features/clustered/queue-message-redistribution/src/main/java/org/apache/activemq/artemis/jms/example/QueueMessageRedistributionExample.java move to amq-broker-7.0.3/examples/features/clustered/queue-message-redistribution mvn clean mvn verify

    Description

      If there is no consumers in clustered brokers, new message will store to the specific queue on a node, but will never redistribute to another nodes even there is a consumer in the another nodes. So messages in the queue at that node can appear to be stranded.

      This is the scenario:

      1. start up 2 clustered broker (redistribution settings are enabled, and "redistribution-delay" is set to 0)
      2. send some messages to a queue on broker-0
      3. start consuming the queue on broker-1
        -> redistribution never occurs
      4. send another message to a queue on broker-0
      5. consumer will only receive the latest message

      Attachments

        Issue Links

          is related to

          Bug - A problem that impairs or prevents the functions of the product. AMQDOC-2853 Customer feedback - Configuring a Point to Point Address/Queue

          • Critical - To be worked on immediately following BLOCKER issues.
          • Closed
          relates to

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-962 Message Lost in Clustered A-MQ7 Brokers When Message Is Sent From EAP Resource Adapter

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed
          cloned to

          ARTEMIS-1612 Loading...

          Activity

            People

              rh-ee-ataylor Andy Taylor
              rhn-support-hfuruich Hisao Furuichi
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: