Return-Path: Delivered-To: apmail-qpid-users-archive@www.apache.org Received: (qmail 17457 invoked from network); 16 Feb 2010 16:32:09 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 16 Feb 2010 16:32:09 -0000 Received: (qmail 80980 invoked by uid 500); 16 Feb 2010 16:32:09 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 80960 invoked by uid 500); 16 Feb 2010 16:32:09 -0000 Mailing-List: contact users-help@qpid.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@qpid.apache.org Delivered-To: mailing list users@qpid.apache.org Received: (qmail 80950 invoked by uid 99); 16 Feb 2010 16:32:09 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 16 Feb 2010 16:32:09 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of ramashish.lists@gmail.com designates 209.85.221.179 as permitted sender) Received: from [209.85.221.179] (HELO mail-qy0-f179.google.com) (209.85.221.179) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 16 Feb 2010 16:32:02 +0000 Received: by qyk9 with SMTP id 9so3300014qyk.22 for ; Tue, 16 Feb 2010 08:31:41 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :date:message-id:subject:from:to:content-type; bh=PnOj6xKVVTsiepNgo1fyCYtT0JtV/aOUAJ4qXrlq210=; b=CIQurZFUtyVv/Xq8D7x5zfXgH0dvVJwndRAYznA097kZzmedvlxEfjqp5wGfo+bnoA GuaVK+bcAM00WoEDtHZ2sVtcecj/TIdKb6KsgcywyTThOrVvoEOX0sCOSsHyYyJ/j3B/ Lp/9eE9jS0CFs5wc4nGSNSHfI7XChGMQuF2PE= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; b=VJYc46h7hMz6q7KFR9vc82xZytijitPtvu9FepVM32Ho49uapl5MCou8cHe2UO0f+A SBWEwPWuJEz5jZoPwgnpXNRDcxHruo/nqGHYhz1I7oaJCz48kecG1MuCOHnLeqd07dpk pVDl+jf+Depg/66wTtz2GR0nNAZwmveHAo6fw= MIME-Version: 1.0 Received: by 10.231.150.142 with SMTP id y14mr1538822ibv.32.1266337901073; Tue, 16 Feb 2010 08:31:41 -0800 (PST) In-Reply-To: <4B758736.4000008@redhat.com> References: <6bd1d93e1002102301k46b68341tc78413603bb416d2@mail.gmail.com> <4B758736.4000008@redhat.com> Date: Tue, 16 Feb 2010 22:01:41 +0530 Message-ID: <6bd1d93e1002160831s79bc596cqd16d81c9c12e16e4@mail.gmail.com> Subject: Re: qpid for multiple producers and consumers From: Ramashish Baranwal To: users@qpid.apache.org Content-Type: text/plain; charset=ISO-8859-1 > > Try setting flow control such that each consumer only gets one message at a > time. I.e. instead of calling start() on the incoming queue (which gives > unlimited credit) allocate credit yourself. (Attached patch attempts to > describe that more precisely). > > --Gordon. > Thanks Gordon! That worked. So it seems the flow control will make the client receive one message at a time, right? However, after receiving just one message, the queue.get() is timing out. Do I need to do something else to continue receiving more messages one at a time? Regards, Ramashish --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:users-subscribe@qpid.apache.org