Major Description
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.
#!/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()
[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
[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 ~]$