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