You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Gordon Sim (Closed) (JIRA)" <ji...@apache.org> on 2011/10/20 17:47:10 UTC
[jira] [Closed] (QPID-2964) Python client is not sending arguments
from messaging address correctly
[ https://issues.apache.org/jira/browse/QPID-2964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gordon Sim closed QPID-2964.
----------------------------
Resolution: Duplicate
Duplicate of QPID-2551
> Python client is not sending arguments from messaging address correctly
> -----------------------------------------------------------------------
>
> Key: QPID-2964
> URL: https://issues.apache.org/jira/browse/QPID-2964
> Project: Qpid
> Issue Type: Bug
> Components: Python Client
> Reporter: Jonathan Robie
>
> The Python and C++ client libraries are sending arguments from messaging addresses in different ways.
> This is easily seen by comparing the C++ and Python implementations of drain, using the same command line:
> $ ./drain -f "xml; {link:{x-bindings:[{key:'weather', arguments:{xquery:\"$(cat rdu.xquery )\"}}]}}"
> Here are the steps needed to reconstruct:
> 1. Create XML exchange:
> ====================
> $ ./qpid-config add exchange xml xml
> 2. Python client (the XML Exchange receives an empty query
> ====================================================
> $ ./drain -f "xml; {link:{x-bindings:[{key:'weather', arguments:{xquery:\"$(cat rdu.xquery )\"}}]}}"
> Traceback (most recent call last):
> File "./drain", line 81, in <module>
> rcv = ssn.receiver(addr)
> File "<string>", line 6, in receiver
> File "/home/jrobie/projects/qpid/pure/qpid/python/qpid/messaging/endpoints.py", line 603, in receiver
> receiver._ewait(lambda: receiver.linked)
> File "/home/jrobie/projects/qpid/pure/qpid/python/qpid/messaging/endpoints.py", line 960, in _ewait
> result = self.session._ewait(lambda: self.error or predicate(), timeout)
> File "/home/jrobie/projects/qpid/pure/qpid/python/qpid/messaging/endpoints.py", line 554, in _ewait
> self.check_error()
> File "/home/jrobie/projects/qpid/pure/qpid/python/qpid/messaging/endpoints.py", line 543, in check_error
> raise self.error
> qpid.messaging.exceptions.ServerError: internal-error: Could not parse xquery: (qpid/xml/XmlExchange.cpp:96)(541)
> Broker output:
> 2010-11-26 10:31:23 trace qpid/amqp_0_10/Connection.cpp:57: RECV [127.0.0.1:59898]: Frame[BEbe; channel=0; {ExchangeBindBody: queue=36361426-3df6-49e2-b70e-7cb22ec24ec3:0.0; exchange=xml; }]
> 2010-11-26 10:31:23 trace qpid/SessionState.cpp:200: anonymous.36361426-3df6-49e2-b70e-7cb22ec24ec3:0: recv cmd 3: {ExchangeBindBody: queue=36361426-3df6-49e2-b70e-7cb22ec24ec3:0.0; exchange=xml; } ##### note empty arguments - confirmed in debugger
> 2010-11-26 10:31:23 trace qpid/xml/XmlExchange.cpp:72: Creating binding with query: ##### note that query is empty
> 2010-11-26 10:31:23 debug qpid/Exception.cpp:31: Exception constructed: Could not parse xquery: (qpid/xml/XmlExchange.cpp:96)
> 2010-11-26 10:31:23 error qpid/amqp_0_10/SessionHandler.cpp:97: Execution exception: internal-error: Could not parse xquery: (qpid/xml/XmlExchange.cpp:96)
> 2010-11-26 10:31:23 trace qpid/amqp_0_10/Connection.cpp:57: RECV [127.0.0.1:59898]: Frame[BEbe; channel=0; {ExchangeBindBody: queue=36361426-3df6-49e2-b70e-7cb22ec24ec3:0.0; exchange=xml; binding-key=weather; arguments={xquery:V2:204:str16(let $w := ./weather return $w/station = 'Raleigh-Durham International Airport (KRDU)' and $w/temperature_f > 50 and $w/temperature_f - $w/dewpoint > 5 and $w/wind_speed_mph > 7 and $w/wind_speed_mph < 20 )}; }] ##### Note that the query actually was sent to the broker
> 2010-11-26 10:31:23 trace qpid/amqp_0_10/Connection.cpp:57: RECV [127.0.0.1:59898]: Frame[BEbe; channel=0; {MessageSubscribeBody: queue=36361426-3df6-49e2-b70e-7cb22ec24ec3:0.0; destination=0; accept-mode=0; acquire-mode=0; }]
> 2010-11-26 10:31:23 trace qpid/amqp_0_10/Connection.cpp:57: RECV [127.0.0.1:59898]: Frame[BEbe; channel=0; {MessageSetFlowModeBody: destination=0; flow-mode=0; }]
> 2010-11-26 10:31:23 trace qpid/amqp_0_10/Connection.cpp:95: SENT [127.0.0.1:59898]: Frame[BEbe; channel=0; {ExecutionExceptionBody: error-code=541; command-id=3; class-code=7; command-code=4; field-index=0; description=internal-error: Could not parse xquery: (qpid/xml/XmlExchange.cpp:96); error-info={}; }]
> 2010-11-26 10:31:23 trace qpid/amqp_0_10/Connection.cpp:95: SENT [127.0.0.1:59898]: Frame[BEbe; channel=0; {SessionDetachBody: name=36361426-3df6-49e2-b70e-7cb22ec24ec3:0; }]
> 2010-11-26 10:31:23 trace qpid/amqp_0_10/Connection.cpp:57: RECV [127.0.0.1:59898]: Frame[BEbe; channel=0; {SessionDetachedBody: name=36361426-3df6-49e2-b70e-7cb22ec24ec3:0; }]
> 2010-11-26 10:31:23 debug qpid/broker/SessionState.cpp:120: anonymous.36361426-3df6-49e2-b70e-7cb22ec24ec3:0: detached on broker.
> Looking at the arguments in the broker:
> Breakpoint 4, 0x00436e7c in qpid::broker::SessionAdapter::ExchangeHandlerImpl::bind (this=0xb604238c, queueName="reply-localhost.localdomain.20520.1", exchangeName="amq.direct", routingKey="reply-localhost.localdomain.20520.1", arguments=...) at ../../cpp/src/qpid/broker/SessionAdapter.cpp:189
> ((gdb) p arguments
> $2 = (const qpid::framing::FieldTable &) @0xb6044918: {values = std::map with 0 elements}
> Compare to C++ client: (works as expected)
> ====================================
> $ ./drain -f "xml; {link:{x-bindings:[{key:'weather', arguments:{xquery:\"$(cat rdu.xquery )\"}}]}}"
> Broker shows query is received and correctly parsed:
> 2010-11-25 13:19:53 trace ../../cpp/src/qpid/amqp_0_10/Connection.cpp:57: RECV [127.0.0.1:47869]: Frame[BEbe; channel=1; {ExchangeBindBody: queue=xml_26cb6be2-13dd-470d-a580-49398755c0f8; exchange=xml; binding-key=weather; arguments={xquery:V2:204:vbin16(let $w := ./weather return $w/station = 'Raleigh-Durham International Airport (KRDU)' and $w/temperature_f > 50 and $w/temperature_f - $w/dewpoint > 5 and $w/wind_speed_mph > 7 and $w/wind_speed_mph < 20 )}; }]
> 2010-11-25 13:19:53 trace ../../cpp/src/qpid/SessionState.cpp:200: anonymous.63665982-bcce-496c-b33f-79c474b29a04: recv cmd 5: {ExchangeBindBody: queue=xml_26cb6be2-13dd-470d-a580-49398755c0f8; exchange=xml; binding-key=weather; arguments={xquery:V2:204:vbin16(let $w := ./weather return $w/station = 'Raleigh-Durham International Airport (KRDU)' and $w/temperature_f > 50 and $w/temperature_f - $w/dewpoint > 5 and $w/wind_speed_mph > 7 and $w/wind_speed_mph < 20 )}; }
> 2010-11-25 13:19:53 trace ../../cpp/src/qpid/xml/XmlExchange.cpp:72: Creating binding with query: let $w := ./weather return $w/station = 'Raleigh-Durham International Airport (KRDU)' and $w/temperature_f > 50 and $w/temperature_f - $w/dewpoint > 5 and $w/wind_speed_mph > 7 and $w/wind_speed_mph < 20
> 2010-11-25 13:19:53 trace ../../cpp/src/qpid/xml/XmlExchange.cpp:78: Bound successfully with query: let $w := ./weather return $w/station = 'Raleigh-Durham International Airport (KRDU)' and $w/temperature_f > 50 and $w/temperature_f - $w/dewpoint > 5 and $w/wind_speed_mph > 7 and $w/wind_speed_mph < 20
> 2010-11-25 13:19:53 trace ../../cpp/src/qpid/management/ManagementAgent.cpp:373: SEND raiseEvent (v1) class=org.apache.qpid.broker.bind
> 2010-11-25 13:19:53 debug ../../cpp/src/qpid/SessionState.cpp:214: anonymous.63665982-bcce-496c-b33f-79c474b29a04: receiver marked completed: 5 incomplete: { } unknown-completed: { [0,5] }
> Looking at the arguments in the debugger:
> #2 0x00436e7c in qpid::broker::SessionAdapter::ExchangeHandlerImpl::bind (this=0x8168bd4, queueName="xml-exchange_5cc7fe9f-8feb-41b1-9b56-6a7816e4498c", exchangeName="xml-exchange", routingKey="weather", arguments=...) at ../../cpp/src/qpid/broker/SessionAdapter.cpp:189
> (gdb) p arguments
> $1 = (const qpid::framing::FieldTable &) @0x8145e88: {values = std::map with 1 elements = {["xquery"] = {px = 0x8115c30, pn = {pi_ = 0x8145f10}}}}
> (gdb)
> rdu.xquery:
> ===========
> let $w := ./weather return $w/station = 'Raleigh-Durham International Airport (KRDU)' and $w/temperature_f > 50 and $w/temperature_f - $w/dewpoint > 5 and $w/wind_speed_mph > 7 and $w/wind_speed_mph < 20
> rdu.xml:
> ===========
> <weather>
> <station>Raleigh-Durham International Airport (KRDU)</station>
> <wind_speed_mph>16</wind_speed_mph>
> <temperature_f>70</temperature_f>
> <dewpoint>35</dewpoint>
> </weather>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org