Uploaded image for project: 'A-MQ Broker'
  1. A-MQ Broker
  2. ENTMQBR-651

Sending a message Core -> AMQP resets message priority

    Details

    • Type: Bug
    • Status: Done
    • Priority: Major
    • Resolution: Rejected
    • Affects Version/s: A-MQ 7.0.0.CR1
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None
    • Target Release:
    • Steps to Reproduce:
      Hide

      Send a message with the Core protocol and receive it with the AMQP protocol

      java  -jar node_data/clients/acce.jar sender --log-msgs dict --broker tcp://127.0.0.1:61616 --address lalaq
      {'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'redelivered': False, 'id': 'ID:6a32948b-2a96-11e7-a178-185e0fec8ce5', 'user_id':None, 'address': 'lalaq', 'subject': None, 'reply_to': None, 'correlation_id': None, 'content_type': None, 'content_encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493221117324, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': '0'}, 'content': None, 'type': None}
      
      % node_data/clients/python/aac5_receiver.py --broker-url "amqp://127.0.0.1/lalaq" --log-msgs dict                                                  
      {'address': 'lalaq', 'annotations': {'x-opt-jms-dest': 0, 'x-opt-jms-msg-type': 0}, 'body': 'Conversion to AMQP error!', 'content': 'Conversion to AMQP error!', 'content_encoding': 'None', 'content_type': 'None', 'correlation_id': None, 'creation_time': 1493221117.324000, 'delivery_count': 0, 'durable': True, 'expiration': 0, 'first_acquirer': False, 'group_id': None, 'group_sequence': 0, 'id': None, 'inferred': False, 'instructions': None, 'priority': 0, 'properties': {'JMSXDeliveryCount': None}, 'reply_to': None, 'reply_to_group_id': None, 'subject': None, 'ttl': 0, 'user_id': ''}
      
      Show
      Send a message with the Core protocol and receive it with the AMQP protocol java -jar node_data/clients/acce.jar sender --log-msgs dict --broker tcp://127.0.0.1:61616 --address lalaq {'durable': True, 'priority': 4, 'ttl': 0, 'first-acquirer': False, 'delivery-count': 0, 'redelivered': False, 'id': 'ID:6a32948b-2a96-11e7-a178-185e0fec8ce5', 'user_id':None, 'address': 'lalaq', 'subject': None, 'reply_to': None, 'correlation_id': None, 'content_type': None, 'content_encoding': None, 'absolute-expiry-time': 0, 'creation-time': 1493221117324, 'group-id': None, 'group-sequence': 0, 'reply-to-group-id': None, 'properties': {'JMSXDeliveryCount': '0'}, 'content': None, 'type': None} % node_data/clients/python/aac5_receiver.py --broker-url "amqp://127.0.0.1/lalaq" --log-msgs dict {'address': 'lalaq', 'annotations': {'x-opt-jms-dest': 0, 'x-opt-jms-msg-type': 0}, 'body': 'Conversion to AMQP error!', 'content': 'Conversion to AMQP error!', 'content_encoding': 'None', 'content_type': 'None', 'correlation_id': None, 'creation_time': 1493221117.324000, 'delivery_count': 0, 'durable': True, 'expiration': 0, 'first_acquirer': False, 'group_id': None, 'group_sequence': 0, 'id': None, 'inferred': False, 'instructions': None, 'priority': 0, 'properties': {'JMSXDeliveryCount': None}, 'reply_to': None, 'reply_to_group_id': None, 'subject': None, 'ttl': 0, 'user_id': ''}

      Description

      Notice that the priority in sent message is 4 and in received message it is 0.

      It works correctly the other way around, AMQP -> Core.

        Gliffy Diagrams

          Attachments

            Issue Links

              Activity

                People

                • Assignee:
                  ataylor Andy Taylor
                  Reporter:
                  jdanek Jiri Danek
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  6 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved: