You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "clebert suconic (JIRA)" <ji...@apache.org> on 2017/03/09 14:34:38 UTC
[jira] [Reopened] (ARTEMIS-1021) JMS Openwire client unable to
receive a message from amqp (qpid cpp) producer (EOFexception)
[ 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)