You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Ted Ross (JIRA)" <ji...@apache.org> on 2014/11/19 21:54:34 UTC
[jira] [Resolved] (DISPATCH-77) Error decoding an integer message
body
[ https://issues.apache.org/jira/browse/DISPATCH-77?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ted Ross resolved DISPATCH-77.
------------------------------
Resolution: Fixed
Message body validation did not accept all valid AMQP type-tags.
The message logging code leaked one field-iterator per message logged.
> Error decoding an integer message body
> --------------------------------------
>
> Key: DISPATCH-77
> URL: https://issues.apache.org/jira/browse/DISPATCH-77
> Project: Qpid Dispatch
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Justin Ross
> Assignee: Ted Ross
> Labels: leak
> Fix For: 0.3
>
>
> The router fails to decode a message with a body that is simply an integer.
> It also appears that repeated sends of this sort result in a lot of unfreed field iterator objects.
> {noformat}
> #!/usr/bin/python
> from qpid_messaging import *
> conn = Connection("localhost:5672", protocol="amqp1.0")
> conn.open()
> try:
> session = conn.session()
> link = session.sender("test")
> link.send(Message(1))
> finally:
> conn.close()
> {noformat}
> {noformat}
> [jross@localhost ~]$ qdrouterd
> Wed Nov 19 11:42:15 2014 SERVER (info) Container Name: Qpid.Dispatch.Router.A
> Wed Nov 19 11:42:15 2014 ROUTER (info) Router started in Standalone mode
> Wed Nov 19 11:42:15 2014 ROUTER (info) In-Process Address Registered: $cmanagement
> Wed Nov 19 11:42:15 2014 ROUTER (info) In-Process Address Registered: $cmanagement
> Wed Nov 19 11:42:15 2014 ROUTER (info) In-Process Address Registered: $management
> Wed Nov 19 11:42:15 2014 ROUTER (info) In-Process Address Registered: $management
> Wed Nov 19 11:42:15 2014 ROUTER (info) Configured Address: prefix=/closest/ phase=0 fanout=QD_SCHEMA_FIXEDADDRESS_FANOUT_SINGLE bias=QD_SCHEMA_FIXEDADDRESS_BIAS_CLOSEST
> Wed Nov 19 11:42:15 2014 ROUTER (info) Configured Address: prefix=/multicast/ phase=0 fanout=QD_SCHEMA_FIXEDADDRESS_FANOUT_MULTIPLE
> Wed Nov 19 11:42:15 2014 ROUTER (info) Configured Address: prefix=/queue/ phase=0 fanout=QD_SCHEMA_FIXEDADDRESS_FANOUT_SINGLE bias=QD_SCHEMA_FIXEDADDRESS_BIAS_CLOSEST
> Wed Nov 19 11:42:15 2014 ROUTER (info) Configured Address: prefix=/queue/ phase=1 fanout=QD_SCHEMA_FIXEDADDRESS_FANOUT_SINGLE bias=QD_SCHEMA_FIXEDADDRESS_BIAS_CLOSEST
> Wed Nov 19 11:42:15 2014 ROUTER (info) Configured Address: prefix=/ phase=0 fanout=QD_SCHEMA_FIXEDADDRESS_FANOUT_MULTIPLE
> Wed Nov 19 11:42:15 2014 CONN_MGR (info) Configured Listener: 0.0.0.0:amqp role=normal
> Wed Nov 19 11:42:15 2014 SERVER (info) Operational, 4 Threads Running
> Wed Nov 19 11:42:16 2014 ERROR (error) Invalid message: Invalid body value
> {noformat}
> {noformat}
> [jross@localhost ~]$ PN_TRACE_FRM=1 ./test.py
> [0x22d1100]: <- AMQP
> [0x22d1100]:0 <- @open(16) [container-id="Qpid.Dispatch.Router.A", max-frame-size=16384, offered-capabilities=:"ANONYMOUS-RELAY"]
> [0x22d1100]: -> AMQP
> [0x22d1100]:0 -> @open(16) [container-id="2c66e74f-a15f-4051-86f4-a338fc7e7e29", properties={:"qpid.client_process"="test.py", :"qpid.client_pid"=15995, :"qpid.client_ppid"=2730}]
> [0x22d1100]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=0]
> [0x22d1100]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=0, incoming-window=61, outgoing-window=0]
> [0x22d1100]:0 -> @attach(18) [name="test_e07dae76-6697-4c75-8482-196c4b4300cb", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="test", durable=0, timeout=0, dynamic=false], target=@target(41) [address="test", durable=0, timeout=0, dynamic=false], initial-delivery-count=0]
> [0x22d1100]:0 <- @attach(18) [name="test_e07dae76-6697-4c75-8482-196c4b4300cb", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="test", durable=0, timeout=0, dynamic=false], target=@target(41) [address="test", durable=0, timeout=0, dynamic=false], initial-delivery-count=0]
> [0x22d1100]:0 <- @flow(19) [next-incoming-id=0, incoming-window=61, next-outgoing-id=0, outgoing-window=0, handle=0, delivery-count=0, link-credit=1000, drain=false]
> Sending
> [0x22d1100]:0 -> @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"\x00\x00\x00\x00", message-format=0, settled=false, more=false] (27) "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\x81\x00\x00\x00\x00\x00\x00\x00\x01"
> [0x22d1100]:0 <- @flow(19) [next-incoming-id=1, incoming-window=61, next-outgoing-id=0, outgoing-window=0, handle=0, delivery-count=1, link-credit=1000, drain=false]
> [0x22d1100]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, state=@released(38) []]
> Sent
> [0x22d1100]:0 -> @end(23) []
> [0x22d1100]:0 -> @close(24) []
> [0x22d1100]: -> EOS
> [0x22d1100]: -> EOS
> [0x22d1100]:0 <- @end(23) []
> [0x22d1100]:0 <- @close(24) []
> [0x22d1100]: <- EOS
> [jross@localhost ~]$
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org