Hi, Yeah, that would be the easiest solution. In my case, the producer and consumers are entirely different java processes and all of them can start and stop randomly. The solution suggested by you could be achieved through database also, but just wanted to avoid making any database schema changes just for this purpose.
Thanks, Kalpana Dejan Bosanac wrote: > > Hi, > > you can save that info in your application and map consumerid with other > info from ConsumerInfo when it is connected. > > Cheers > -- > Dejan Bosanac - http://twitter.com/dejanb > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Fri, Apr 30, 2010 at 8:57 AM, Kalpana Jalawadi < > kalpana.jalaw...@gmail.com> wrote: > >> >> Hi, >> >> I'm using AdvisoryConsumer in my MessageProducer to listen to the >> consumers >> activities. On a consumer shutdown, I would want to perform some cleanup >> job. Below is the code: >> >> Topic advisoryTopic = AdvisorySupport >> .getConsumerAdvisoryTopic((ActiveMQDestination) >> JMSConnection.getInstance().getTopic()); >> MessageConsumer advisoryConsumer = >> JMSConnection.getInstance().getSession().createConsumer(advisoryTopic); >> advisoryConsumer.setMessageListener(new MessageListener() { >> public void onMessage(Message message) { >> if (message instanceof ActiveMQMessage) { >> ActiveMQMessage aMsg = (ActiveMQMessage) message; >> >> DataStructure dataStructure = aMsg.getDataStructure(); >> if (dataStructure instanceof ConsumerInfo) { >> System.out.println("Consumer started, ConsumerInfo >> :" + message.toString()); >> ... >> } else if (dataStructure instanceof RemoveInfo) { >> RemoveInfo removeInfo = (RemoveInfo) >> dataStructure; >> DataStructure objectId = removeInfo.getObjectId(); >> System.out.println("Consumer stopped, ConsumerInfo >> :" + message.toString()); >> // do some clean up >> } >> } >> } >> }); >> >> RemoveInfo command, exposes the consumerId (some magic string consisting >> of >> connection id, session id and some long value), is there a way to find >> the >> subscription name that is specified while creating the consumer using the >> consumer id that is available to me? Or any other work around where I >> could >> clearly identify who is the consumer who is dead? >> Any help w.r.t this would be highly appreciated. >> >> Thanks! >> -- >> View this message in context: >> http://old.nabble.com/AdvisoryConsumer-tp28409087p28409087.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://old.nabble.com/AdvisoryConsumer-tp28409087p28409312.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
