From dev-return-23149-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org Wed Nov 10 15:34:14 2010 Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 79501 invoked from network); 10 Nov 2010 15:34:13 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 10 Nov 2010 15:34:13 -0000 Received: (qmail 58909 invoked by uid 500); 10 Nov 2010 15:34:45 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 58768 invoked by uid 500); 10 Nov 2010 15:34:43 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 58652 invoked by uid 99); 10 Nov 2010 15:34:42 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Nov 2010 15:34:42 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.22] (HELO thor.apache.org) (140.211.11.22) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Nov 2010 15:34:41 +0000 Received: from thor (localhost [127.0.0.1]) by thor.apache.org (8.13.8+Sun/8.13.8) with ESMTP id oAAFYKRC003125 for ; Wed, 10 Nov 2010 15:34:21 GMT Message-ID: <4863042.391289403260063.JavaMail.jira@thor> Date: Wed, 10 Nov 2010 10:34:20 -0500 (EST) From: "Alexis Bietti (JIRA)" To: dev@activemq.apache.org Subject: [jira] Commented: (AMQ-762) Message Group based load balancing not well distributed across brokers MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c [ https://issues.apache.org/activemq/browse/AMQ-762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=63241#action_63241 ] Alexis Bietti commented on AMQ-762: ----------------------------------- Possibly related issue: exclusive consumers don't work either across brokers. > Message Group based load balancing not well distributed across brokers > ---------------------------------------------------------------------- > > Key: AMQ-762 > URL: https://issues.apache.org/activemq/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 " 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 " > "close " > and "exit" > NOTE: The command "close " 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.