Justin Ross created DISPATCH-77:
-----------------------------------
Summary: Error decoding an iinteger 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
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: [email protected]
For additional commands, e-mail: [email protected]
