[
https://issues.apache.org/jira/browse/ARTEMIS-1021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michal Toth updated ARTEMIS-1021:
---------------------------------
Description:
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}
was:
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}
> 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)
