Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 27686 invoked from network); 26 Jul 2007 10:05:42 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 26 Jul 2007 10:05:42 -0000 Received: (qmail 46944 invoked by uid 500); 26 Jul 2007 10:05:43 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 46795 invoked by uid 500); 26 Jul 2007 10:05:42 -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 46786 invoked by uid 99); 26 Jul 2007 10:05:42 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 26 Jul 2007 03:05:42 -0700 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (herse.apache.org: domain of jlim@exist.com designates 64.233.162.228 as permitted sender) Received: from [64.233.162.228] (HELO nz-out-0506.google.com) (64.233.162.228) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 26 Jul 2007 03:05:39 -0700 Received: by nz-out-0506.google.com with SMTP id z3so372485nzf for ; Thu, 26 Jul 2007 03:05:18 -0700 (PDT) Received: by 10.115.75.1 with SMTP id c1mr1565807wal.1185444318316; Thu, 26 Jul 2007 03:05:18 -0700 (PDT) Received: from ?192.168.241.147? ( [58.71.13.205]) by mx.google.com with ESMTPS id m28sm3098249poh.2007.07.26.03.05.16 (version=TLSv1/SSLv3 cipher=RC4-MD5); Thu, 26 Jul 2007 03:05:17 -0700 (PDT) Message-ID: <46A871DA.20500@exist.com> Date: Thu, 26 Jul 2007 18:05:14 +0800 From: Jonas Lim User-Agent: Thunderbird 1.5.0.12 (Windows/20070509) MIME-Version: 1.0 To: dev@activemq.apache.org Subject: Re: Advisory messages References: <11797326.post@talk.nabble.com> <11801248.post@talk.nabble.com> In-Reply-To: <11801248.post@talk.nabble.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Hi Jim, Could you raise a jira for this please : https://issues.apache.org/activemq/secure/CreateIssue!default.jspa thanks, Jonas jhunsinger wrote: > Updated Information: > > I copied some code from the ProducerEventSource which assumes that if the > data structure is an instanceof ProducerInfo, then the advisory msg is an > add (start) producer. If the data structure is an instanceof RemoveInfo, > then it is a remove (stop) producer. I also noticed that the property > producerCount is only provided for RemoveInfo and not ProducerInfo. > > Seems like the producerCount property should be available in the advisory > message when both adding and removing a producer to/from a destination. I > also didn't see any mbean information for destination producerCount. > > Jim > > > > jhunsinger wrote: > >> Hello, >> >> I am trying to start/stop java processes upon the receipt of a message on >> a queue. I created a simple Advisory example that subscribes to >> ActiveMQ.Advisory.Producer.Queue.>. However, I do not see how to >> determine if this a producer start or stop. I would also like to >> determine the number of producers and consumers on a queue. Is there an >> easy way to determine the above? >> >> Thanks, >> Jim >> >> > >