Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id ABC8A200C32 for ; Thu, 9 Mar 2017 17:20:44 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id AA768160B64; Thu, 9 Mar 2017 16:20:44 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id CB247160B87 for ; Thu, 9 Mar 2017 17:20:43 +0100 (CET) Received: (qmail 35641 invoked by uid 500); 9 Mar 2017 16:20:43 -0000 Mailing-List: contact issues-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list issues@activemq.apache.org Received: (qmail 35631 invoked by uid 99); 9 Mar 2017 16:20:43 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 09 Mar 2017 16:20:43 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 92C091806A4 for ; Thu, 9 Mar 2017 16:20:42 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.452 X-Spam-Level: * X-Spam-Status: No, score=1.452 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, RP_MATCHES_RCVD=-0.001, SPF_NEUTRAL=0.652, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id SVu2umsFNgkv for ; Thu, 9 Mar 2017 16:20:40 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 48C1960FBA for ; Thu, 9 Mar 2017 16:20:40 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 39161E0596 for ; Thu, 9 Mar 2017 16:20:39 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 597B4243C0 for ; Thu, 9 Mar 2017 16:20:38 +0000 (UTC) Date: Thu, 9 Mar 2017 16:20:38 +0000 (UTC) From: "clebert suconic (JIRA)" To: issues@activemq.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (ARTEMIS-1021) JMS Openwire client unable to receive a message from amqp (qpid cpp) producer (EOFexception) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Thu, 09 Mar 2017 16:20:44 -0000 [ 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)