Tim, Thanks for the reply. The tutorial looks great. I have a few more questions though.
Specifically, I am trying to use topic://ActiveMQ.Advisory.TempQueue but there doesn't seem to be any msg properties that I can leverage and I have no visibility into the body of the messages that come across this topic. According to ActiveMQ documentation (http://activemq.apache.org/advisory-message.html) the properties and data structure are null for messages on this topic. Is this correct? I would think a message on this topic would at the very least have the temporary queue name and whether it was just created or destroyed. This is the kind of information I am looking for. I want to know if a client is gone by knowing when its temporary (reply) queue goes away. I have a simple consumer (TestAdvisory) that subscribes to "topic://ActiveMQ.Advisory.>". Below is output from this consumer. I start the TestAdvisory consumer and then start another test application that connects to ActiveMQ and immediately creates a temporary queue to act as its reply queue. Here is the output from TestAdvisory when I start the application and then stop it: Output: {TestAdvisory started} {test application started} Message received on ActiveMQ.Advisory.Connection (msg type = Unknown) Property: originBrokerId = ID:<host>-58822-1245008598443-0:0 Property: originBrokerName = localhost Property: originBrokerURL = vm://localhost Message received on ActiveMQ.Advisory.TempQueue (msg type = Unknown) Property: originBrokerId = ID:<host>-58822-1245008598443-0:0 Property: originBrokerName = localhost Property: originBrokerURL = vm://localhost Message received on ActiveMQ.Advisory.Consumer.Queue.b74906ba-b930-df85-100a-abec448e4189:0 (msg type = Unknown) Property: consumerCount = 1 Property: originBrokerId = ID:<host>-58822-1245008598443-0:0 Property: originBrokerName = localhost Property: originBrokerURL = vm://localhost {test application stopped} Message received on ActiveMQ.Advisory.TempQueue (msg type = Unknown) Property: originBrokerId = ID:<host>-58822-1245008598443-0:0 Property: originBrokerName = localhost Property: originBrokerURL = vm://localhost Message received on ActiveMQ.Advisory.Connection (msg type = Unknown) Property: originBrokerId = ID:<host>-58822-1245008598443-0:0 Property: originBrokerName = localhost Property: originBrokerURL = vm://localhost {TestAdvisory stopped} As you can see from the output, I am iterating over the message properties and displaying them. I am also getting the destination from the message and I try to determine the message type by doing dynamic_cast checks against sub-classes of cms::Message. I assume the two messages that come across topic://ActiveMQ.Advisory.TempQueue are advising of the temporary queue of the application being created and destroyed but I can't verify that with code since there are no useful message properties and also since the message type is unknown (I am assuming it is an object message). So after all that... my question is, how can I get useful information out of the messages on ActiveMQ.Advisory.TempQueue? >From everything I have read about CMS, the answer is you can't because CMS can't handle Java Object messages. I understand if this is the case and can look at alternatives but I just want to make sure I am not missing something here. If interested, here is the code in TestAdvisory that generated the above output (compiled against ActiveMQ-CPP v2.2.2): void TestAdvisory::handleMessage(cms::Message* p_message) { string msgType = "Unknown"; if (dynamic_cast<cms::BytesMessage*>(p_message)) { msgType = "Bytes"; } else if (dynamic_cast<cms::MapMessage*>(p_message)) { msgType = "Map"; } //else if (dynamic_cast<cms::ObjectMessage*>(p_message)) //{ //msgType = "Object"; //} else if (dynamic_cast<cms::TextMessage*>(p_message)) { msgType = "Text"; } const cms::Destination *dest = p_message->getCMSDestination(); cout << endl << "Message received on " + dest->toProviderString() + " (msg type = " << msgType << ")" << endl; vector<pair<string, string> > destProps = dest->getCMSProperties().toArray(); for (vector<pair<string, string> >::iterator itr = destProps.begin(); itr != destProps.end(); itr++) { cout << "Dest Property: " << itr->first << " = " << itr->second << endl; } vector<string> properties = p_message->getPropertyNames(); for (vector<string>::iterator itr = properties.begin(); itr != properties.end(); itr++) { try { cout << "Property: " << *itr << " = " << p_message->getStringProperty(*itr) << endl; } catch (...) { cout << "Property: " << *itr << " = " << p_message->getIntProperty(*itr) << endl; } } } -- View this message in context: http://www.nabble.com/ActiveMQ-CPP-and-Advisory-messages-tp23983516p24026003.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
