Hi again Gordon et al.
I'm making progress with this :-) so thanks for all the info so far.
Firstly with respect to the topic being subscribed to for events
"qmf.default.topic/agent.ind.event.org_apache_qpid_broker.#" is this
actually documented anywhere? I had a look through the QMF Wiki pages but
couldn't seen any info at all on the topics used by QMF (it also seems to
use qmf.default.direct for request/response - but again I can't find any
documentation).
I'd have never worked that stuff out without your help.......
Secondly you said "The messages you receive on that will be amqp-list
formatted messages". It seems that Events are actually amqp-map formatted
(the QMF Wiki says "_data_indication List of <qmf.content> " too, but this
seems to be wrong given what I've seen in practice).
See the following snippet from my hacky onMessage()
public void onMessage(Message message) {
try {
MapMessage msg = (MapMessage)message;
Map schemaId = (Map)msg.getObject("_schema_id");
String className = new
String((byte[])schemaId.get("_class_name"));
System.out.println(className);
I'll keep you all posted and if I get anything worthwhile put together I'll
post it.
Cheers,
Fraser
Gordon Sim wrote:
>
>
> You can create a receiver/message consumer with address
> qmf.default.topic/agent.ind.event.org_apache_qpid_broker.#
>
> The messages you receive on that will be amqp-list formatted messages
> (from JMS you would need to decode these as per my previous example as
> the library won't yet do it for you). Each entry will be an event
> represented as a map.
>
> event["_schema_d"]["_class_name"] will contain the class of the event.
> In your case you are interested in clientConnect and clientDisconnect
>
>
--
View this message in context:
http://apache-qpid-users.2158936.n2.nabble.com/Is-it-possible-to-write-a-client-that-gets-notified-of-connections-disconnections-to-broker-tp6487251p6492378.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
