Uploaded image for project: 'ActiveMQ Artemis'
  1. ActiveMQ Artemis
  2. ARTEMIS-1021

JMS Openwire client unable to receive a message from amqp (qpid cpp) producer (EOFexception)

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Not A Problem
    • 2.0.0
    • None
    • AMQP, OpenWire
    • None

    • artemis-1009 branch

    Description

      Qpid cpp client is unable to receive a message produced by Openwire client.

      0) Create address+queue in broker.xml (iQ)

      1) Send a message using qpid cpp client

      /var/dtests/node_data/clients/aac0_sender  --log-msgs dict --broker admin:admin@localhost:5672 --connection-options "{  reconnect : 'true', sasl_mechanisms : 'PLAIN', protocol : 'amqp1.0' }" --address iQ --count 1 --msg-content "MSG no.%d" 
{'redelivered': False, 'reply_to': None, 'subject': None, 'content_type': 'text/plain', 'id': None, 'user_id': None, 'correlation_id': None, 'priority': 0, 'durable': False, 'ttl': 0.000000e+00, 'size': 8, 'properties': {}, 'content': 'MSG no.0'}

      2) receive it using openwire client

      [1,root@mt_r6x0 ~]$ java  -jar /var/dtests/node_data/clients/aoc7.jar receiver  --log-msgs dict --broker tcp://localhost:61616 --conn-reconnect True --conn-username admin --conn-password admin --address "iQ" --count 1
Error while printing content from message
javax.jms.MessageEOFException: java.io.EOFException
	at org.apache.activemq.util.JMSExceptionSupport.createMessageEOFException(JMSExceptionSupport.java:84)
	at org.apache.activemq.command.ActiveMQBytesMessage.readUTF(ActiveMQBytesMessage.java:453)
	at com.redhat.mqe.jms.MessageFormatter.formatContent(MessageFormatter.java:280)
	at com.redhat.mqe.jms.MessageFormatter.printMessageAsDict(MessageFormatter.java:57)
	at com.redhat.mqe.jms.CoreClient.printMessage(CoreClient.java:382)
	at com.redhat.mqe.jms.ReceiverClient.consumeMessage(ReceiverClient.java:185)
	at com.redhat.mqe.jms.ReceiverClient.startClient(ReceiverClient.java:107)
	at com.redhat.mqe.jms.aoc7_receiver.main(aoc7_receiver.java:30)
	at com.redhat.mqe.jms.Main.main(Main.java:29)
Caused by: java.io.EOFException
	at java.io.DataInputStream.readFully(DataInputStream.java:197)
	at java.io.DataInputStream.readUTF(DataInputStream.java:609)
	at java.io.DataInputStream.readUTF(DataInputStream.java:564)
	at org.apache.activemq.command.ActiveMQBytesMessage.readUTF(ActiveMQBytesMessage.java:451)
	... 7 more

      clebertsuconic should know about this one.

      Also another interoperability might be some extra binary data when consuming as AMQP, while producer was Openwire. If you want me to create another jira, let me know please and I will move this to new jira.

      Openwire sender

java  -jar /var/dtests/node_data/clients/java/aoc/target/aoc7-downstream-ga-5.11.0.redhat-621084.jar sender  --log-msgs dict --broker tcp://localhost:61616 --conn-reconnect True --conn-username admin --conn-password admin --address "interopQ" --count 5 --msg-content "Message content of msg number %d"

{'redelivered': False, 'reply_to': None, 'id': 'mySuperHost-41469-1488804202031-1:1:1:1:1', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202386, 'address': 'queue://interopQ', 'properties': {}, 'content': 'Message content of msg number 0'}
{'redelivered': False, 'reply_to': None, 'id': 'mySuperHost-41469-1488804202031-1:1:1:1:2', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202412, 'address': 'queue://interopQ', 'properties': {}, 'content': 'Message content of msg number 1'}
{'redelivered': False, 'reply_to': None, 'id': 'mySuperHost-41469-1488804202031-1:1:1:1:3', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202416, 'address': 'queue://interopQ', 'properties': {}, 'content': 'Message content of msg number 2'}
{'redelivered': False, 'reply_to': None, 'id': 'mySuperHost-41469-1488804202031-1:1:1:1:4', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202419, 'address': 'queue://interopQ', 'properties': {}, 'content': 'Message content of msg number 3'}
{'redelivered': False, 'reply_to': None, 'id': 'mySuperHost-41469-1488804202031-1:1:1:1:5', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202423, 'address': 'queue://interopQ', 'properties': {}, 'content': 'Message content of msg number 4'}

 

AMQP receiver
java  -jar /var/dtests/node_data/clients/java/aac/target/aac1-downstream-0.11.0.redhat-1.jar receiver  --log-msgs dict  --conn-username admin --conn-password admin --address "interopQ" --count 0

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00Jn\x02\xae\x02{\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01\x00\x01

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00F{\x01+\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01

{'redelivered': False, 'reply_to': None, 'id': None, 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202386, 'address': 'interopQ', 'properties': {'__HDR_COMMAND_ID': 5, 'JMSXDeliveryCount': 1, '__HDR_ARRIVAL': 0, '__HDR_MESSAGE_ID': , '__HDR_GROUP_SEQUENCE': 0, '__HDR_PRODUCER_ID': , '__HDR_DROPPABLE': False, '__HDR_BROKER_IN_TIME': 1488804202388, '_AMQ_DUPL_ID': 'mySuperHost-41469-1488804202031-1:1:1:1:1'}, 'content': 'Message content of msg number 0'}

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00Jn\x02\xae\x02{\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01\x00\x02

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00F{\x01+\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01

{'redelivered': False, 'reply_to': None, 'id': None, 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202412, 'address': 'interopQ', 'properties': {'__HDR_COMMAND_ID': 6, 'JMSXDeliveryCount': 1, '__HDR_ARRIVAL': 0, '__HDR_MESSAGE_ID': , '__HDR_GROUP_SEQUENCE': 0, '__HDR_PRODUCER_ID': , '__HDR_DROPPABLE': False, '__HDR_BROKER_IN_TIME': 1488804202414, '_AMQ_DUPL_ID': 'mySuperHost-41469-1488804202031-1:1:1:1:2'}, 'content': 'Message content of msg number 1'}

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00Jn\x02\xae\x02{\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01\x00\x03

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00F{\x01+\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01

{'redelivered': False, 'reply_to': None, 'id': None, 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202416, 'address': 'interopQ', 'properties': {'__HDR_COMMAND_ID': 7, 'JMSXDeliveryCount': 1, '__HDR_ARRIVAL': 0, '__HDR_MESSAGE_ID': , '__HDR_GROUP_SEQUENCE': 0, '__HDR_PRODUCER_ID': , '__HDR_DROPPABLE': False, '__HDR_BROKER_IN_TIME': 1488804202417, '_AMQ_DUPL_ID': 'mySuperHost-41469-1488804202031-1:1:1:1:3'}, 'content': 'Message content of msg number 2'}

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00Jn\x02\xae\x02{\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01\x00\x04

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00F{\x01+\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01

{'redelivered': False, 'reply_to': None, 'id': None, 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202419, 'address': 'interopQ', 'properties': {'__HDR_COMMAND_ID': 8, 'JMSXDeliveryCount': 1, '__HDR_ARRIVAL': 0, '__HDR_MESSAGE_ID': , '__HDR_GROUP_SEQUENCE': 0, '__HDR_PRODUCER_ID': , '__HDR_DROPPABLE': False, '__HDR_BROKER_IN_TIME': 1488804202420, '_AMQ_DUPL_ID': 'mySuperHost-41469-1488804202031-1:1:1:1:4'}, 'content': 'Message content of msg number 3'}

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00Jn\x02\xae\x02{\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01\x00\x05

Unsupported object type org.apache.qpid.proton.amqp.Binary \x00\x00\x00F{\x01+\x00=ID:mySuperHost-41469-1488804202031-1:1\x00\x01\x00\x01

{'redelivered': False, 'reply_to': None, 'id': None, 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1488804202423, 'address': 'interopQ', 'properties': {'__HDR_COMMAND_ID': 9, 'JMSXDeliveryCount': 1, '__HDR_ARRIVAL': 0, '__HDR_MESSAGE_ID': , '__HDR_GROUP_SEQUENCE': 0, '__HDR_PRODUCER_ID': , '__HDR_DROPPABLE': False, '__HDR_BROKER_IN_TIME': 1488804202424, '_AMQ_DUPL_ID': 'mySuperHost-41469-1488804202031-1:1:1:1:5'}, 'content': 'Message content of msg number 4'}
dhcp

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #1076

          Activity

            People

              Unassigned Unassigned
              michalxo Michal Toth
              Votes:
              0 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: