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/08 21:10:38 UTC
[jira] [Closed] (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 closed ARTEMIS-1021.
------------------------------------
Resolution: Cannot Reproduce
I expanded ConsumerTest to send and receive Text Message exchanging AMQP and OpenWire clients and I couldn't replicate this issue.
I will need a duplicator if there is any issues, but it seems it's an issue with your body on your client. If you expect conversions to JMS on other types you should use proper conventions.. otherwise send AMQP / receive AMQP and it should work.
> 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
>
> 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)