[ARTEMIS-2608] ClassCastException when consuming a message using OpenWire

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.11.0
• Fix Version/s: 2.12.0
• Component/s: AMQP, OpenWire
• Assignee: Unassigned
• Reporter: Federico Valeri
• Created: 25/Jan/20 13:48
• Updated: 16/Apr/20 22:47
• Resolved: 16/Apr/20 22:47

Description

This issue seems to be related to the conversion of binary properties.
Quick workaround: clear message properties in the AMQP producer.

Reproducer (attached):
1. Send a message to the broker using OpenWire client
2. Consume that message using AMQP client
3. Send that message back to the broker using AMQP client

Result: message could not be consumed by the OpenWire consumer.

2020-01-23 12:52:44,095 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.lang.ClassCastException: org.apache.activemq.artemis.api.core.SimpleString cannot be cast to [B
 at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:629) [artemis-openwire-protocol-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:501) [artemis-openwire-protocol-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:258) [artemis-openwire-protocol-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:312) [artemis-openwire-protocol-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1161) [artemis-server-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:504) [artemis-server-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:3510) [artemis-server-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2856) [artemis-server-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$2300(QueueImpl.java:122) [artemis-server-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:3848) [artemis-server-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]
 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_232]
 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_232]
 at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.11.0-SNAPSHOT.jar:2.11.0-SNAPSHOT]

 

Issue Links

• links to: GitHub Pull Request #2954