[
https://issues.apache.org/jira/browse/ARTEMIS-1021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15902565#comment-15902565
]
Michal Toth commented on ARTEMIS-1021:
--------------------------------------
I will pass this to our c++ guys to debug it. It seems like the "wrong body" is
in our internal counter for each message. Once it is used the message can't be
used processed by broker properly. It might be a client in a cpp bug.
Thank you [~clebertsuconic]!
> 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)
