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

Sending a message Core -> AMQP resets message priority

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Won't Do
    • Icon: Major Major
    • None
    • A-MQ 7.0.0.CR1
    • None
    • None
    • 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': ''}

      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.

              rh-ee-ataylor Andy Taylor
              jdanek@redhat.com Jiri Daněk
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

                Created:
                Updated:
                Resolved: