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

AMQP messages are not sent to forwarding-address of divert in AMQ 7.7

    XMLWordPrintable

Details

    • Bug
    • Resolution: Not a Bug
    • Major
    • None
    • AMQ 7.7.0.GA
    • amqp-protocol
    • None
    • False
    • False
    • Undefined
    • Hide
      • Attached is the broker.xml. Use it for AMQ 7.7 instance.
      • Send messages with command
        ./artemis producer --url tcp://localhost:5671 --user admin --password admin --message-size 1000 --message-count 1 --destination topic://VirtualTopic.ops.pde.border.authority.sender.request --protocol amqp
        
        
      • Check queue stat 
        [cpandey@cpandey bin]$ ./artemis queue stat --url tcp://localhost:61615
        |NAME                     |ADDRESS                  |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED |
        |Consumer.SendToBorderAuthorityV2.VirtualTopic.ops.pde.border.authority.sender.request|VirtualTopic.ops.pde.border.authority.sender.request|0              |1             |1              |0                |0              |
        |Consumer.X.VirtualTopic.ops.pde.storeevent|Consumer.X.VirtualTopic.ops.pde.storeevent|0              |0             |0              |0                |0              |
        
        
      • Now if we use same broker.xml( queue and divert configurations) with AMQ 7.4 and send amqp message similarly, we get queue stat as 
        [cpandey@cpandey bin]$ ./artemis queue stat --url tcp://localhost:61615
        |NAME                     |ADDRESS                  |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED |
        |Consumer.SendToBorderAuthorityV2.VirtualTopic.ops.pde.border.authority.sender.request|VirtualTopic.ops.pde.border.authority.sender.request|0              |1             |1              |0                |0              |
        |Consumer.X.VirtualTopic.ops.pde.storeevent|Consumer.X.VirtualTopic.ops.pde.storeevent|0              |1             |1              |0                |0              |
        
        
      • Here for AMQ 7.4.0 if we note that message is forwarded to forwarding-address "Consumer.X.VirtualTopic.ops.pde.storeevent". This is correct behavior.
      Show
      Attached is the broker.xml. Use it for AMQ 7.7 instance. Send messages with command ./artemis producer --url tcp: //localhost:5671 --user admin --password admin --message-size 1000 --message-count 1 --destination topic://VirtualTopic.ops.pde.border.authority.sender.request --protocol amqp Check queue stat  [cpandey@cpandey bin]$ ./artemis queue stat --url tcp: //localhost:61615 |NAME |ADDRESS |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED | |Consumer.SendToBorderAuthorityV2.VirtualTopic.ops.pde.border.authority.sender.request|VirtualTopic.ops.pde.border.authority.sender.request|0 |1 |1 |0 |0 | |Consumer.X.VirtualTopic.ops.pde.storeevent|Consumer.X.VirtualTopic.ops.pde.storeevent|0 |0 |0 |0 |0 | Now if we use same broker.xml( queue and divert configurations) with AMQ 7.4 and send amqp message similarly, we get queue stat as  [cpandey@cpandey bin]$ ./artemis queue stat --url tcp: //localhost:61615 |NAME |ADDRESS |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED | |Consumer.SendToBorderAuthorityV2.VirtualTopic.ops.pde.border.authority.sender.request|VirtualTopic.ops.pde.border.authority.sender.request|0 |1 |1 |0 |0 | |Consumer.X.VirtualTopic.ops.pde.storeevent|Consumer.X.VirtualTopic.ops.pde.storeevent|0 |1 |1 |0 |0 | Here for AMQ 7.4.0 if we note that message is forwarded to forwarding-address "Consumer.X.VirtualTopic.ops.pde.storeevent". This is correct behavior.

    Attachments

      Issue Links

        Activity

          People

            gtully@redhat.com Gary Tully
            rhn-support-cpandey Chandra Shekhar Pandey (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: