activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "clebert suconic (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-1021) JMS Openwire client unable to receive a message from amqp (qpid cpp) producer (EOFexception)
Date Thu, 09 Mar 2017 16:20:38 GMT

    [ https://issues.apache.org/jira/browse/ARTEMIS-1021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903311#comment-15903311
] 

clebert suconic commented on ARTEMIS-1021:
------------------------------------------

https://github.com/apache/activemq-artemis/pull/1076

> 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)

Mime
View raw message