Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 11663 invoked from network); 24 Mar 2008 22:47:39 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 24 Mar 2008 22:47:39 -0000 Received: (qmail 41204 invoked by uid 500); 24 Mar 2008 22:47:38 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 41110 invoked by uid 500); 24 Mar 2008 22:47:38 -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 41101 invoked by uid 99); 24 Mar 2008 22:47:38 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Mar 2008 15:47:38 -0700 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.140] (HELO brutus.apache.org) (140.211.11.140) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Mar 2008 22:46:56 +0000 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id AA430234C0B2 for ; Mon, 24 Mar 2008 15:45:32 -0700 (PDT) Message-ID: <683537072.1206398732696.JavaMail.jira@brutus> Date: Mon, 24 Mar 2008 15:45:32 -0700 (PDT) From: "David Jencks (JIRA)" To: dev@activemq.apache.org Subject: [jira] Commented: (AMQ-1632) PrefetchSubscription may not wake up if messages delivered in transaction In-Reply-To: <84853990.1206340232654.JavaMail.jira@brutus> MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/activemq/browse/AMQ-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=41769#action_41769 ] David Jencks commented on AMQ-1632: ----------------------------------- I talked with Hiram a bit and we decided that the real problem was that prefetchSize was being calculated wrong. MDBs instances for an activation spec all share a single multithreaded consumer. So the prefetch size ought to be maxMessagesPerSession * maxSessions, so each mdb gets a chance at maxMessagesPerSession. Previously prefetchSize = maxMessagesPerSession which resulted in some mdbs never getting a chance to process anything if maxMessagesPerSession < maxSessions. Still haven't looked at trunk. > PrefetchSubscription may not wake up if messages delivered in transaction > ------------------------------------------------------------------------- > > Key: AMQ-1632 > URL: https://issues.apache.org/activemq/browse/AMQ-1632 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 4.1.1 > Reporter: David Jencks > Assignee: David Jencks > Fix For: 4.1.2 > > > we noticed mdbs w/transaction on don't work if the prefetch size is less than the number of sessions for the mdb. There's an error in calculating the prefetchExtension in afterCommit and there's no notification that it might be time to send more messages. Apparently if the prefetch size is large enough one of the earlier acks triggers delivery of the next batch. > There are also a bunch of synchronization errors in some classes... -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.