qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (DISPATCH-77) Error decoding an integer message body
Date Wed, 19 Nov 2014 20:50:34 GMT

    [ https://issues.apache.org/jira/browse/DISPATCH-77?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14218480#comment-14218480
] 

ASF subversion and git services commented on DISPATCH-77:
---------------------------------------------------------

Commit 1640628 from [~tedross] in branch 'dispatch/trunk'
[ https://svn.apache.org/r1640628 ]

DISPATCH-77 - Accept any valid type-tag when validating AMQP-Value message bodies.
              Removed tabs.

> 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


Mime
View raw message