XML exchange not receiving any message

[Tomáš Šoltys <to...@gmail.com>]

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 }"
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

Re: XML exchange not receiving any message

[Gordon Sim <gs...@redhat.com>]

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