You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Michal Toth (JIRA)" <ji...@apache.org> on 2017/03/06 13:19:32 UTC

[jira] [Created] (ARTEMIS-1021) JMS Openwire client unable to receive a message from amqp (qpid cpp) producer (EOFexception)

Michal Toth created ARTEMIS-1021:
------------------------------------

             Summary: 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}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)