Description
Steps to reproduce
- Start one interior router and one edge router using the attached config files
- Start a receiver using simple_recv.py and connect it to the interior router
python simple_recv.py -m1 --address 0.0.0.0:77778/examples
- Use the attached sender to send an anonymous message to the edge router
python simple_send_anon.py --address 0.0.0.0:5672 -m1
- The message must travel from the edge router to the interior router which in turn must forward it to the receiver. Instead the message is released as seen in the below frame trace.
[0x5603df87eb20]: -> SASL [0x5603df87eb20]: <- SASL [0x5603df87eb20]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:ANONYMOUS]] [0x5603df87eb20]:0 -> @sasl-init(65) [mechanism=:ANONYMOUS, initial-response=b"anonymous@localhost.localdomain"] [0x5603df87eb20]:0 <- @sasl-outcome(68) [code=0] [0x5603df87eb20]: -> AMQP [0x5603df87eb20]:0 -> @open(16) [container-id="c99c4867-447c-424a-8b4f-e8a406c71a57", hostname="0.0.0.0", channel-max=32767] [0x5603df87eb20]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x5603df87eb20]:0 -> @attach(18) [name="c99c4867-447c-424a-8b4f-e8a406c71a57-8db0b3b7-ffde-4c99-9d99-ee8f3c0d9efd", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0] [0x5603df87eb20]: <- AMQP [0x5603df87eb20]:0 <- @open(16) [container-id="Edge_66t2+y4DnWql1Vx", max-frame-size=16384, channel-max=32767, idle-time-out=8000, offered-capabilities=:"ANONYMOUS-RELAY", properties={:product="qpid-dispatch-router", :version="1.8.0-SNAPSHOT", :"qd.conn-id"=7}] [0x5603df87eb20]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x5603df87eb20]:0 <- @attach(18) [name="c99c4867-447c-424a-8b4f-e8a406c71a57-8db0b3b7-ffde-4c99-9d99-ee8f3c0d9efd", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [durable=0, expiry-policy=:"session-end", timeout=0, dynamic=false], target=@target(41) [durable=0, expiry-policy=:"session-end", timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0] [0x5603df87eb20]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647, next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=250, drain=false] [0x5603df87eb20]:0 -> @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"1", message-format=0] (53) "\x00SpE\x00Ss\xd0\x00\x00\x00\x11\x00\x00\x00\x03S\x01@\xa1\x08examples\x00Sw\xd1\x00\x00\x00\x10\x00\x00\x00\x02\xa1\x08sequenceT\x01" [0x5603df87eb20]:0 <- @flow(19) [next-incoming-id=1, incoming-window=2147483647, next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=1, link-credit=250, drain=false] [0x5603df87eb20]:0 <- @disposition(21) [role=true, first=0, settled=true, state=@released(38) []] [0x5603df87eb20]:0 -> (EMPTY FRAME) [0x5603df87eb20]:0 -> (EMPTY FRAME) ^C[gmurthy@localhost examples]$
Attachments
Attachments
Issue Links
- links to