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 87D1510605 for ; Thu, 10 Oct 2013 05:19:38 +0000 (UTC) Received: (qmail 58872 invoked by uid 500); 10 Oct 2013 05:19:37 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 58847 invoked by uid 500); 10 Oct 2013 05:19:36 -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 58839 invoked by uid 99); 10 Oct 2013 05:19:36 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 10 Oct 2013 05:19:36 +0000 X-ASF-Spam-Status: No, hits=0.6 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of rajdavies@gmail.com designates 74.125.82.53 as permitted sender) Received: from [74.125.82.53] (HELO mail-wg0-f53.google.com) (74.125.82.53) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 10 Oct 2013 05:19:31 +0000 Received: by mail-wg0-f53.google.com with SMTP id y10so86851wgg.8 for ; Wed, 09 Oct 2013 22:19:10 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=content-type:mime-version:subject:from:in-reply-to:date :content-transfer-encoding:message-id:references:to; bh=EKmnAG6dRGjgpg+2H0EkhhjsxdqkY+ILK57+79NwNwI=; b=Gx0Ql+iykijuaq5DksWVOJaav4VIucs8WEAP/GFoQLteg7X8sfsWeI247jjGSoHrrW dXucaq9ON/qUdYV1gc1dWBistsx+hHQ0AAu0/mnve6nhyRmBgUEMfzGmU9HfuJhNy3TG V1F5SGQlz/Lz4eOUkzWul3HUJfm17DKCIXbXVPpzeGq+eRJqmPmZ65HN2FTjXCC/UZ/l sN9Z3CAzz4jWlN8TVXSLeTTiSq5a7/6/qvQXiqXbwCMDAEuBTBLO0jgQ9b40Dw5Odtuf F1jgsnuI9ZDbbbo29EeAfyUaf8moHKz1aTpswsguLL2K/fz7rmWilCf486BUfSKbpl8I hY0Q== X-Received: by 10.180.89.98 with SMTP id bn2mr5895524wib.42.1381382349925; Wed, 09 Oct 2013 22:19:09 -0700 (PDT) Received: from rajdmac.home (host86-136-122-140.range86-136.btcentralplus.com. [86.136.122.140]) by mx.google.com with ESMTPSA id ev4sm21716485wib.7.1969.12.31.16.00.00 (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Wed, 09 Oct 2013 22:19:09 -0700 (PDT) Content-Type: text/plain; charset=us-ascii Mime-Version: 1.0 (Mac OS X Mail 6.6 \(1510\)) Subject: Re: Too many advisories topics created in ActiveMQ From: Robert Davies In-Reply-To: <4CB65FB8-1361-48AB-9782-E11586150C5F@gmail.com> Date: Thu, 10 Oct 2013 06:19:09 +0100 Content-Transfer-Encoding: quoted-printable Message-Id: <11EBD0E0-7C24-400A-8136-FCACDFFA9045@gmail.com> References: <1381378292338-4672501.post@n4.nabble.com> <6FF1E7CE-3F09-4A6A-8E86-115973B1CDE5@gmail.com> <4CB65FB8-1361-48AB-9782-E11586150C5F@gmail.com> To: users@activemq.apache.org X-Mailer: Apple Mail (2.1510) X-Virus-Checked: Checked by ClamAV on apache.org Johan - we should add these to the faq entry (which is looking a little = old - it mentions lingo!)=20 On 10 Oct 2013, at 06:14, Johan Edstrom wrote: > As Rob pointed out, there are several solutions to this, the simplest = one=20 > being as in the old joke, Dr, it hurts when I do this. - Don't do it? >=20 > You could achieve the same thing with one queue and selectors - *which = could run CPU up* > You could use a temp queue per processing unit and handle a lot of = messages (This is nice for pub/sub) > You could use one queue and a bit of instanceof code (It looks a bit = crufty but it is very functional) >=20 >=20 > On Oct 9, 2013, at 11:05 PM, Robert Davies = wrote: >=20 >> What you have described is a bit of an anti-pattern - there's some = guidelines here in the faq: = http://activemq.apache.org/how-should-i-implement-request-response-with-jm= s.html >> Its an anti-pattern because there is a lot of broker side over head = with creating temporary destinations and consumers (as you are seeing).=20= >> However, for your case you probably need to enable GC on destinations = - see http://activemq.apache.org/delete-inactive-destinations.html >>=20 >> On 10 Oct 2013, at 05:11, javaG wrote: >>=20 >>>=20 >>> In my application, I use request-reply by creating temp queue and = creating a >>> new replyConsumer for each message to use replyConsumer.poll() = method to get >>> reply back. After getting reply I close the replyConsumer. Messaging = works >>> fine but each time a message is sent a topic >>> ActiveMQ.Advisory.Consumer.Queue.ID:xxxxxxxxxxxxxx is created and = remains >>> there. So if millions of messages are sent millions of rows will be = created >>> in the ActiveMQ web console for topics. I tried to disable = advisories >>> message to solve this problem but then request-reply does not work = anymore >>> as it throws exceptions like Cannot publish to a deleted = destination. So I >>> am stuck. Any one has a solution? >>>=20 >>> Thanks >>>=20 >>>=20 >>>=20 >>>=20 >>>=20 >>> -- >>> View this message in context: = http://activemq.2283324.n4.nabble.com/Too-many-advisories-topics-created-i= n-ActiveMQ-tp4672501.html >>> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >>=20 >=20