Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 3C74A200C4C for ; Mon, 20 Mar 2017 15:50:30 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 398CA160B76; Mon, 20 Mar 2017 14:50:30 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 843D7160B81 for ; Mon, 20 Mar 2017 15:50:29 +0100 (CET) Received: (qmail 42219 invoked by uid 500); 20 Mar 2017 14:50:28 -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 42043 invoked by uid 99); 20 Mar 2017 14:50:27 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Mar 2017 14:50:27 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 486D61AFBFA for ; Mon, 20 Mar 2017 14:50:27 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.962 X-Spam-Level: ** X-Spam-Status: No, score=2.962 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, KAM_LIVE=1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001, URI_HEX=1.313, URI_TRY_3LD=0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id qDxF-b66ACNQ for ; Mon, 20 Mar 2017 14:50:26 +0000 (UTC) Received: from mail-qk0-f171.google.com (mail-qk0-f171.google.com [209.85.220.171]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id A86EB5F488 for ; Mon, 20 Mar 2017 14:50:25 +0000 (UTC) Received: by mail-qk0-f171.google.com with SMTP id v127so111991980qkb.2 for ; Mon, 20 Mar 2017 07:50:25 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=subject:to:references:from:message-id:date:user-agent:mime-version :in-reply-to:content-transfer-encoding; bh=XSvaF9Thyb3+h9GmNm4+GwyMwxt6yJ6qkLjHazczc1A=; b=uNHwwcwfwGpr3LddqEeqC/Vx42dWgdNu9sdtulQD75oWKa++U619MvW4cGPKGnnGMK MEJyyFxTUFdu1TQIVE3dvrD/ob2amxwF6f4qYMjfbcH3RD6H7L4zdHITZIpwmuJkFbw4 1GxBPaz8McPUENfmRwfDE5HA/xE/+K/u8I36+qYpg6Z1iZb1ipqibRZOmcuFuikcnxuu SXAjYrWC3ebZ9WiMKN9MrFrdo6dBxt20pi6Fq+tuc8ip+HIJ23MPhYMwllQJIVH9azyd fMWIiyBmB87H7uchfSGuHH9hgMfj0hMwlmKiie8e9mZOI+pXDApQ2XNkbhqtLBbazoR6 zKyA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:subject:to:references:from:message-id:date :user-agent:mime-version:in-reply-to:content-transfer-encoding; bh=XSvaF9Thyb3+h9GmNm4+GwyMwxt6yJ6qkLjHazczc1A=; b=BpUo8ZKOSn4W3/0eUWC/I56atgtVrsu99EUDEojzvwU/ofeieH4ffHtfXnqzo4w6wI KPSRymXFZzl5k2d0OeqEh7Gmv03m17s9Y2xyxGcDTd60LSfDgOMYFBe3QX/q6iK0Fp2K pqzd5tqqOeOkVCV9V/1HlekaRQvB3HzyT8O1NAA5kmSoF76m1QrbOE0sV6CC/T1A2AG+ 0/Y4M+Bt7s8bmzf+Uzgox0noJW30+II3uRKVMjsl5fDpN/ZXykaybPs3li/a02d5TiaL /S8jHCb7tSV3nGzxiF4freD23xI6U2Lbo1RN/2MJJN/DBq8tBRbEqzKv+GrNGSahzj// ezSw== X-Gm-Message-State: AFeK/H1j3c2pAKvf7BTsYePOiuUL4NPJMokaCDKKNtcvjGVdZaVRxbVJq2pUKPTufIWKzQ== X-Received: by 10.55.45.133 with SMTP id t127mr24821490qkh.218.1490021418569; Mon, 20 Mar 2017 07:50:18 -0700 (PDT) Received: from [192.168.2.150] (c-73-191-41-186.hsd1.va.comcast.net. [73.191.41.186]) by smtp.googlemail.com with ESMTPSA id k4sm1254606qta.5.2017.03.20.07.50.17 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Mon, 20 Mar 2017 07:50:17 -0700 (PDT) Subject: Re: NMS.ActiveMQ.Producer deal with OnProducerAck To: dev@activemq.apache.org References: <1490000826211-4723881.post@n4.nabble.com> From: Timothy Bish Message-ID: <91d36cbc-5aa0-a554-f41f-f4293cbd7500@gmail.com> Date: Mon, 20 Mar 2017 10:50:17 -0400 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:45.0) Gecko/20100101 Thunderbird/45.7.0 MIME-Version: 1.0 In-Reply-To: <1490000826211-4723881.post@n4.nabble.com> Content-Type: text/plain; charset=windows-1252; format=flowed Content-Transfer-Encoding: 7bit archived-at: Mon, 20 Mar 2017 14:50:30 -0000 The producer window size bits of NMS.ActiveMQ were not very well tested so it could be there's a bug. There is not access to the outside for the events that are part of this exchange so nothing you can do on your side. If you want to debug and provide a fix and some tests we are happy to accept contributions. On 03/20/2017 05:07 AM, xinchangan wrote: > I am using NMS.ActiveMQ packages to send byte stream through a Queue with > asynchronous and non-persistent mode. I have set ProducerWindowSize to keep > the producer from occupying too much memory on the side of broker. But It > seems the ProducerWindowSize +ProducerFlowControl have no any effect on the > usage of my broker's memory and make the ActiveMQ halt everytime. > > Can I capture and deal with the notification from the broker relevant to > the excess of ProducerWindowSize? In fact I can't find a proper entry to get > into OnProducerAck using NMS IMessageProducer interface. Are there any other > solutions in the .net environment to cope with this issue? > > Thanks. > > > > > > -- > View this message in context: http://activemq.2283324.n4.nabble.com/NMS-ActiveMQ-Producer-deal-with-OnProducerAck-tp4723881.html > Sent from the ActiveMQ - Dev mailing list archive at Nabble.com. > -- Tim Bish twitter: @tabish121 blog: http://timbish.blogspot.com/