Return-Path: X-Original-To: apmail-qpid-users-archive@www.apache.org Delivered-To: apmail-qpid-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 04030D9F7 for ; Fri, 3 Aug 2012 13:30:31 +0000 (UTC) Received: (qmail 22874 invoked by uid 500); 3 Aug 2012 13:30:30 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 22833 invoked by uid 500); 3 Aug 2012 13:30:30 -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 22825 invoked by uid 99); 3 Aug 2012 13:30:30 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Aug 2012 13:30:30 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=RCVD_IN_DNSWL_NONE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of fraser.adams@blueyonder.co.uk designates 81.103.221.47 as permitted sender) Received: from [81.103.221.47] (HELO mtaout01-winn.ispmail.ntl.com) (81.103.221.47) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Aug 2012 13:30:20 +0000 Received: from know-smtpout-1.server.virginmedia.net ([62.254.123.1]) by mtaout01-winn.ispmail.ntl.com (InterMail vM.7.08.04.00 201-2186-134-20080326) with ESMTP id <20120803133000.HFQP28961.mtaout01-winn.ispmail.ntl.com@know-smtpout-1.server.virginmedia.net> for ; Fri, 3 Aug 2012 14:30:00 +0100 Received: from [82.33.36.91] (helo=[192.168.1.2]) by know-smtpout-1.server.virginmedia.net with esmtpa (Exim 4.63) (envelope-from ) id 1SxHwh-0001Bv-0N for users@qpid.apache.org; Fri, 03 Aug 2012 14:29:39 +0100 Message-ID: <501BD234.8010305@blueyonder.co.uk> Date: Fri, 03 Aug 2012 14:29:24 +0100 From: Fraser Adams User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:14.0) Gecko/20120714 Thunderbird/14.0 MIME-Version: 1.0 To: users@qpid.apache.org Subject: Re: more memory "leak" woes. References: <4F4F8FE4.9020404@redhat.com> <501BAB24.3020108@blueyonder.co.uk> <501BBBE0.5090305@redhat.com> <501BC5A8.4000204@blueyonder.co.uk> <501BCA5C.1040802@redhat.com> <501BCA99.6040003@redhat.com> In-Reply-To: <501BCA99.6040003@redhat.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Cloudmark-Analysis: v=1.1 cv=AUhbpHVS+xhHrj9wLCYAQoYnFLYUZdbP8UM0GmH2jwk= c=1 sm=0 a=aFP-xk0SXQ8A:10 a=fhEzjh6MuhkA:10 a=3NElcqgl2aoA:10 a=8nJEP1OIZ-IA:10 a=LvR0ZZiJzDljQrQRmEIA:9 a=wPNLvfGTeEIA:10 a=HpAAvcLHHh0Zw7uRqdWCyQ==:117 On 03/08/12 13:56, Gordon Sim wrote: > On 08/03/2012 01:55 PM, Gordon Sim wrote: >> On 08/03/2012 01:35 PM, Fraser Adams wrote: >>> subscription = subscriptions.subscribe(*this, queue); >>> >>> subscription.setFlowControl(FlowControl::messageWindow(100)); // Why >>> doesn't this work :-( ??? >>> subscription.setAutoAck(10); >> >> When you say it didn't work, what exactly do you mean? That it behaved >> like the messaqeCredit() call? or that it didn't restrict the window? >> >> Try setting the option on subscribe, rather than after it. E.g. >> >> subscription = subscriptions.subscribe(*this, queue, >> SubscriptionSettings(FlowControl::messageCredit(100))); > > Sorry! That should read messageWindow() of course!! > So yeah when I tried subscription.setFlowControl(FlowControl::messageWindow(100)); It behaved as if I hadn't done anything and my memory consumption grew out of control. I've now tried subscription = subscriptions.subscribe(*this, queue, SubscriptionSettings(FlowControl::messageWindow(100))); subscription.setAutoAck(10); As you suggested here and both qpidd and client-consumer seem happier - qpidd is on ~320M and client-consumer is on ~220M SHR according to top and are both fairly stable. Any idea why calling setFlowControl() on the subscription didn't work? It seems confusing to have a method call that doesn't appear to work... On my other questions - so now I've got flow control working can you suggest how to configure a qpid::client consumer to use unreliable messaging? So if I can configure client-consumer with unlimited flow control and unreliable messaging will that be a fair emulation of a broker bridge with a slow consumer hanging off it. I might then be able to try it with my 0.12 broker then a 0.8 broker and see if they behave differently - if they do then that just *might* be our smoking gun - what do you think (unless you already know the answer). Cheers, Frase --------------------------------------------------------------------- To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org For additional commands, e-mail: users-help@qpid.apache.org