Uploaded image for project: 'AMQ Interconnect'
  1. AMQ Interconnect
  2. ENTMQIC-2203

Anonymous messages are released by edge router even if there is a receiver for the messages

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • 1.4.1.GA
    • 1.4.0.GA
    • Qpid Dispatch Router
    • None
    • Release Notes
    • Hide
      There was a defect in AMQ Interconnect that affected senders connected to Edge routers and using anonymous sending links. In that scenario, messages sent were not delivered to consumers connected to other routers in the network. This has been fixed in the current release.
      Show
      There was a defect in AMQ Interconnect that affected senders connected to Edge routers and using anonymous sending links. In that scenario, messages sent were not delivered to consumers connected to other routers in the network. This has been fixed in the current release.
    • Documented as Resolved Issue
    • IC-2019-05

    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

        Activity

          People

            gmurthy@redhat.com Ganesh Murthy
            gmurthy@redhat.com Ganesh Murthy
            Fernando Giorgetti Fernando Giorgetti
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: