1024cainiao

sendAndReceive throw exception Message cannot be cast to MessageExt

5

env: rocketmq-spring-boot-starter:2.2.2 question: use org.apache.rocketmq.spring.core.RocketMQTemplate#sendAndReceive(java.lang.String, org.springframework.messaging.Message, java.lang.reflect.Type) throw exception `java.lang.ClassCastException: org.apache.rocketmq.common.message.Message cannot be cast to org.apache.rocketmq.common.message.MessageExt at org.apache.rocketmq.spring.core.RocketMQTemplate.sendAndReceive(RocketMQTemplate.java:245) ~[rocketmq-spring-boot-2.2.2.jar:2.2.2] at org.apache.rocketmq.spring.core.RocketMQTemplate.sendAndReceive(RocketMQTemplate.java:117) ~[rocketmq-spring-boot-2.2.2.jar:2.2.2] at com.wjk.rocketmq.boot.producer.MyProducer.sendAndReceive(MyProducer.java:93) ~[classes/:na] at com.wjk.rocketmq.boot.controller.TestController.sendAndReceive(TestController.java:51) ~[classes/:na] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native...