qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gordon Sim <g...@redhat.com>
Subject Re: XML exchange not receiving any message
Date Mon, 11 Mar 2013 13:33:07 GMT
On 03/01/2013 01:04 PM, Tomáš Šoltys wrote:
> Hi,
>
> I am trying to setup an  XMLexchange and send some message to it. Here is
> what I did but for some reason I do not see any messages on the exchange.
> Can someone please tell me what am I doing wrong?
>
>
> $> qpid-config -a admin/admin@cbgd03:29999 add exchange xml xml-exchange
> $> qpid-config -a admin/admin@cbgd03:29999 add queue xml-queue
> $> qpid-config -a admin/admin@cbgd03:29999 bind xml-exchange xml-queue
> XMLtest -f xquery.xml
>
>
> content of xquery.xml:
> ------------------------------------------------------------------------
> let $w := ./FIXML return $w/TrdCaptRpt/@TransTyp = 2
> ------------------------------------------------------------------------
>
>
> Python scripts which sends message:
> ------------------------------------------------------------------------
> #! /usr/bin/python
>
> import sys
> from qpid.messaging import *
> from qpid.log import enable, DEBUG
>
> request_address = "xml-exchange; { node: { type: topic, x-declare: { type:
> xml } }, create: never }"

Your binding uses XMLtest as a binding key and this has to match the 
routing key on any message before the xquery will even be evaluated. You 
could change the above address to "xml-exchange/XMLtest; { node: { type: 
topic, x-declare: { type: xml } }, create: never }" to do that (or else 
set the subject of the message before sending it).

> reply_adress = "response/response_queue; { create: receiver, node: { type:
> topic } }"
>
> connection = Connection(host="myhost", port=21234, username="user",
> password="pass")
>
> try:
>      connection.open()
>      session = connection.session()
>      sender = session.sender(request_address)
>
>      message_text = "<FIXML><TrdCaptRpt TransTyp=2></TrdCaptRpt></FIXML>"
>      message = Message(message_text, durable=True, reply_to=reply_adress)
>
>      sender.send(message, sync=False, timeout=1000);
>      sender.sync(1000)
>
>      session.acknowledge()
>
> except MessagingError,m:
>      print m
>
> finally:
>      connection.close()
> ------------------------------------------------------------------------
>
> Regards,
> Tomas Soltys
>


---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org


Mime
View raw message