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 <darricks...@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.
