[ 
https://issues.apache.org/jira/browse/AMQ-762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Dejan Bosanac updated AMQ-762:
------------------------------

    Fix Version/s:     (was: 5.4.2)
                   5.5.0

> Message Group based load balancing not well distributed across brokers
> ----------------------------------------------------------------------
>
>                 Key: AMQ-762
>                 URL: https://issues.apache.org/jira/browse/AMQ-762
>             Project: ActiveMQ
>          Issue Type: Improvement
>    Affects Versions: 4.0
>         Environment: Active MQ 4.0, Lingo 1.1
>            Reporter: Sanjiv Jivan
>             Fix For: 5.5.0
>
>         Attachments: lingocluster.zip
>
>
> I started 2 servers, each of which have an embedded broker. A shell based 
> chield sends messages to 30 different message groups (using command "register 
> <message group>" in the samepl app provided. Only 2 mesages are received by 
> server1, 3 by server2 and 25 by server3. The load balancing distribution is 
> highly unenen. 
> As suggested, I also tried setting a low destination queue prefetch value 
> (consumer.prefetch=1) but the result was the same.
> To run sample :
> 1. Unzip attached file and run "maven.bat" from the oot directory (Maven 1.0)
> 2. Open 3 DOS boxes in the dist\bin folder and run 
> "startoptimizerPooled.bat", "startOptimizerPooled2.bat" and 
> "startOptimizerPooled3.bat" in each DOS box respectively.
> 3. Step 2 starts a network of 3 servers apps which have an embedded broker. 
> The Spring configuration files for each of these servers is in the dist\conf 
> directory.
> 4. Open another DOS box in dist\bin and start a test client by running 
> "startClientShell.bat"
> 5. This command driver test client accepts commads in the form 
> "register <message group>"
> "close <message group>"
> and "exit"
> NOTE: The command "close <message group>" is supposed to close/reset  the 
> message group by issueing a "JMSXGroupSeq" header as described here : 
> http://www.activemq.org/site/message-groups.html
> 6. Try sending several messages to the server by issuing several commands 
> like "regeister A", "register B", "register C" and so on.. You'll see the 
> highly uneven distibution of messages. Only one or two messages are received 
> my 2 servers while the third one receives a majority of the messages.
> Please let me know if you have trouble running the sample or replicating the 
> issue. 
> Thanks,
> Sanjiv

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to