Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-8731

Messages sent to fqqn:// address destination are silently sent to nowhere if routing type = multicast

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Unresolved
    • Icon: Undefined Undefined
    • None
    • None
    • None
    • None
    • False
    • None
    • False

      reporting this as a bug after discussing with gtully@redhat.com
      Opposite problem from apache:
      https://issues.apache.org/jira/browse/ARTEMIS-4212

      Steps to reproduce:
      1. Create multicast topic on broker
      2. Attempt to send messages to fqqn:// address:

      ./amq-broker/bin/artemis producer --url tcp://filter-test-ss-0:5672 --protocol amqp --destination fqqn://exampleTopic --message-count 100
      

      This results in broker topic reporting routed message amount, but messages are silently removed.
      This might be a usability problem.

      Trace logs from sending attempt:

      
      Message CoreMessage[messageID=37,durable=true,userID=null,priority=0, timestamp=Tue Jan 30 14:10:32 GMT 2024,expiration=0, durable=true, address=activemq.notifications,size=691,properties=TypedProperties[_AMQ_User=NULL-value,_AMQ_Distance=0,_AMQ_SessionName=5450bfc9-bf79-11ee-b7ec-0a580a810349,_AMQ_Protocol_Name=AMQP,_AMQ_Address=activemq.notifications,_AMQ_NotifType=SESSION_CREATED,_AMQ_Client_ID=ID:b859b506-a15a-4d80-b959-4ece0b95d460:2,_AMQ_NotifTimestamp=1706623832159,_AMQ_ConnectionName=db517601]]@1568217645 is not going anywhere as it didn't have a binding on address:activemq.notifications
      AMQ601262: User K3XkcnbT(admin)@10.129.3.73:57286 is creating address on target resource: 5450bfc9-bf79-11ee-b7ec-0a580a810349 with parameters: [Address [name=exampleTopic, id=10, routingTypes={MULTICAST,ANYCAST}, autoCreated=false, paused=false, bindingRemovedTimestamp=-1, swept=false, createdTimestamp=1706623809198], true]
      checking access permissions to exampleTopic
      checking access permissions to exampleTopic
      send(message=AMQPStandardMessage( [durable=true, messageID=38, address=exampleTopic::queuewithfilter, size=258, scanningStatus=SCANNED, applicationProperties={ThreadSent=Producer exampleTopic::queuewithfilter, thread=0, count=0}, messageAnnotations={x-opt-jms-dest=0, x-opt-jms-msg-type=5}, properties=Properties{messageId=ID:d4d03bd2-1a54-4172-9fcc-157a3eebfa95:2:1:1-1, userId=null, to='exampleTopic::queuewithfilter', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Tue Jan 30 14:10:32 GMT 2024, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = null], direct=true) being called
      checking access permissions to exampleTopic
      routing 11 is ignored as routing type did not match
      PostOffice::simpleRoute returned bindings with size = 2
      Message after routed=AMQPStandardMessage( [durable=true, messageID=38, address=exampleTopic::queuewithfilter, size=258, scanningStatus=SCANNED, applicationProperties={ThreadSent=Producer exampleTopic::queuewithfilter, thread=0, count=0}, messageAnnotations={x-opt-jms-dest=0, x-opt-jms-msg-type=5}, properties=Properties{messageId=ID:d4d03bd2-1a54-4172-9fcc-157a3eebfa95:2:1:1-1, userId=null, to='exampleTopic::queuewithfilter', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Tue Jan 30 14:10:32 GMT 2024, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = null]
      RoutingContextImpl(Address=exampleTopic, routingType=ANYCAST, PreviousAddress=null previousRoute:null, reusable=false, version=0)
      

            Unassigned Unassigned
            mkrutov Mikhail Krutov
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated: