Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 85138 invoked from network); 1 Apr 2011 11:25:42 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 1 Apr 2011 11:25:42 -0000 Received: (qmail 25209 invoked by uid 500); 1 Apr 2011 11:25:42 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 25164 invoked by uid 500); 1 Apr 2011 11:25:42 -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 25134 invoked by uid 99); 1 Apr 2011 11:25:42 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Apr 2011 11:25:42 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Apr 2011 11:25:39 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 98ADD8DAB4 for ; Fri, 1 Apr 2011 11:22:20 +0000 (UTC) Date: Fri, 1 Apr 2011 11:22:20 +0000 (UTC) From: "Gary Tully (JIRA)" To: dev@activemq.apache.org Message-ID: <1615590363.27671.1301656940622.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Updated] (AMQ-2286) NetworkConnector PrefetchSize MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/AMQ-2286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Tully updated AMQ-2286: ---------------------------- Fix Version/s: (was: 5.5.0) 5.6.0 > NetworkConnector PrefetchSize > ----------------------------- > > Key: AMQ-2286 > URL: https://issues.apache.org/jira/browse/AMQ-2286 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 5.2.0 > Environment: Sun solaris 10 > Reporter: ying > Fix For: 5.6.0 > > > I have an issue which greatly reduces the quality of service of a network of activemq brokers. > Here is what I have: > 1. 4 brokers( broker1, broker2, broker3, broker4) in a network by multicast discovery > 2. i have 2 consumers of QueueA on broker1, 2 consumers of QueueA on broker2, and consumer queuePrefetch=1, networkConnector prefetchSize=1. Queue is using RoundRobinDispatchPolicy > 3. I publish to QueueA on broker3 with 100 msgs, 2 consumers on broker1 are fast and they process fine but 2 consumers on broker2 are stuck. However, with this config, msgs are still 50 goes to broker1, 50 goes to broker2, and when consumers on broker2 get stuck, those 50 msgs are stuck on broker2. It seems the prefetchSize=1 on networkConnector have no effect at all. > what I expect in this case will be that 98 msgs shall go to broker1, and only 2 msgs stuck on broker2's consumers. I cannot lose a single msg so ConstantPendingMessageLimit will not help. > Please help. Thanks -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira