From users-return-28720-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Thu Sep 1 10:26:07 2011 Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 83BD68E8A for ; Thu, 1 Sep 2011 10:26:07 +0000 (UTC) Received: (qmail 56048 invoked by uid 500); 1 Sep 2011 10:26:06 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 55467 invoked by uid 500); 1 Sep 2011 10:25:51 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 55458 invoked by uid 99); 1 Sep 2011 10:25:49 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Sep 2011 10:25:49 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=FREEMAIL_FROM,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of gary.tully@gmail.com designates 209.85.216.171 as permitted sender) Received: from [209.85.216.171] (HELO mail-qy0-f171.google.com) (209.85.216.171) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Sep 2011 10:25:44 +0000 Received: by qyk36 with SMTP id 36so28676qyk.2 for ; Thu, 01 Sep 2011 03:25:23 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type:content-transfer-encoding; bh=eEB6E067e+QFVhm+OwiCIh5iDi5z0Pe/YSASFwRnatI=; b=xF72mSBI2VCR4RWMsnTNrVg8ozoQzre95jwf3TpiiqERbsxgerx9WA+LM3ZzP0YF4R kxfLG0XKZXGyrZEEBfkX9lND0Wfdi39083imPmW46QITvaScm1eYqmearbX7u2yih+xf t7RMSiaw5+0exlmrOasEip4UEpEn+xUiaugsc= MIME-Version: 1.0 Received: by 10.229.28.200 with SMTP id n8mr15169qcc.291.1314872723307; Thu, 01 Sep 2011 03:25:23 -0700 (PDT) Received: by 10.229.232.195 with HTTP; Thu, 1 Sep 2011 03:25:23 -0700 (PDT) In-Reply-To: <3689034a.d71a.1321f814efa.Coremail.suonayi2006@163.com> References: <3689034a.d71a.1321f814efa.Coremail.suonayi2006@163.com> Date: Thu, 1 Sep 2011 11:25:23 +0100 Message-ID: Subject: Re: Consumer wait for next batched messages for several seconds? From: Gary Tully To: users@activemq.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable if you are acking the messages, new messages will get dispatched as they are acknowledged. The broker trys to maintain the 1000 (which is the default prefetch) buffered messages on a consumer. 2011/8/31 SuoNayi : > Hi,all.After setting producerFlowControl to be false in the broker,my tes= t which keeps sending messages to broker =A0reached 7000msg/s. > > That's a good news but when I set up a message listener on one consumer.I= found that each time the consumer consumed the batched messages, default 1= 000, > > it will wait for the next batched messages to consume and this break take= s several seconds. Does this normally? > > --=20 http://fusesource.com http://blog.garytully.com