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 lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <21922620.post@talk.nabble.com>
Date: Mon, 9 Feb 2009 13:41:10 -0800 (PST)
From: darrickc <darrickspam@gmail.com>
To: users@activemq.apache.org
Subject: Re: Can someone point me to an example of using a
 ConsumerEventSource
In-Reply-To: <36e91d9d0902090401q3c7d0566lcebf6de99d59c4e0@mail.gmail.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
References: <21882293.post@talk.nabble.com>
 <36e91d9d0902090401q3c7d0566lcebf6de99d59c4e0@mail.gmail.com>


That did the trick! Thanks!


Dejan Bosanac wrote:
> 
> 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.
>>
>>
> 
> 
> -----
> Dejan Bosanac
> 
> Open Source Integration - http://fusesource.com/
> ActiveMQ in Action - http://www.manning.com/snyder/
> Blog - http://www.nighttale.net
> 

-- 
View this message in context: http://www.nabble.com/Can-someone-point-me-to-an-example-of-using-a-ConsumerEventSource-tp21882293p21922620.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.