[ https://issues.apache.org/jira/browse/ARTEMIS-1021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
clebert suconic reopened ARTEMIS-1021: -------------------------------------- > JMS Openwire client unable to receive a message from amqp (qpid cpp) producer > (EOFexception) > -------------------------------------------------------------------------------------------- > > Key: ARTEMIS-1021 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1021 > Project: ActiveMQ Artemis > Issue Type: Bug > Components: AMQP, OpenWire > Affects Versions: 2.0.0 > Environment: artemis-1009 branch > Reporter: Michal Toth > Priority: Blocker > Attachments: artemis-1021_repro.tar.gz > > > 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 > {noformat} > /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'} > {noformat} > 2) receive it using openwire client > {noformat} > [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 > {noformat} > [~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. > {noformat} > 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 > {noformat} -- This message was sent by Atlassian JIRA (v6.3.15#6346)