Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of chubrilo@gmail.com designates
 209.85.220.20 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:sender:in-reply-to:references:date
         :x-google-sender-auth:message-id:subject:from:to:content-type;
        b=WrjzyyauXhhOF/Z0dBD0YGQ3A8odiO5W4GNu0ScZqSj07YjD1bRSiAQAB5dYZaRNWn
         NztQIECsB6oKyLZAJGY0k/VYRdSqCpgBV8XQlIDkGVpihLjVBaQYNM9YeJKNrH/0dvBD
         ZFX2vef9vWr35SRyGeD6IIMjDToEYbrN3RiUw=
MIME-Version: 1.0
Sender: chubrilo@gmail.com
In-Reply-To: <21882293.post@talk.nabble.com>
References: <21882293.post@talk.nabble.com>
Date: Mon, 9 Feb 2009 13:01:49 +0100
Message-ID: <36e91d9d0902090401q3c7d0566lcebf6de99d59c4e0@mail.gmail.com>
Subject: Re: Can someone point me to an example of using a ConsumerEventSource
From: Dejan Bosanac <dejan@nighttale.net>
To: users@activemq.apache.org
Content-Type: multipart/alternative; boundary=001636417647b482bc04627b2259

--001636417647b482bc04627b2259
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit

Hi,

try starting the ConsumerEvenetSource (ces.start()).

Cheers
--
Dejan Bosanac

Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net


On Fri, Feb 6, 2009 at 11:49 PM, darrickc <darrickspam@gmail.com> wrote:

>
> I have an embedded broker in my server process and I'd like to know in my
> server process when a client subscribes to a certain topic. Through reading
> these forums I've figured out that using a ConsumerEventSource is the way
> to
> go. When I get an event I can figure out how many consumers there are for a
> topic like:
>
> public void onConsumerEvent( ConsumerEvent consumerEvt )
> {
>        numOfConsumers = consumerEvt.getConsumerCount()
> }
>
> Here is how I've setup my consumer for ConsumerEvents:
>
>
> // here topic is something like "Something.status.STOP"
> //but I've also tried "ActiveMQ.Advisory.Consumer.Topic."+topic
> destination = session.createTopic(topic);
>
> //Here the connection is the connection in the server that is used to
> publish messages on to the consumers.
> ConsumerEventSource ces = new ConsumerEventSource(connection, destination);
> ConsumerListener listener = new SubscriberListener(topic);
> //subscriberListener implements ConsumerListener
> ces.setConsumerListener( listener );
>
> Am I missing something here?
> --
> View this message in context:
> http://www.nabble.com/Can-someone-point-me-to-an-example-of-using-a-ConsumerEventSource-tp21882293p21882293.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>

--001636417647b482bc04627b2259--