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

Broker Does Not Redistribute Existing Messages

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major 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

      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

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

                Created:
                Updated:
                Resolved: