apache / apache/rocketmq-spring
onMessage ClassCastException in abstract class implements RocketMQListener<String>
- Dominant language
- Java
- Stars
- 2.3k
- Forks
- 943
- PR merge metrics
- No merged PRs in 30d
Description
### send Message of Json : {"orderId":1659159656985006081,"systemType":"00"}
### why consume message failed ? Exception Unrepeatable
### stack_trace
java.lang.ClassCastException: java.util.LinkedHashMap cannot be cast to java.lang.String
at com.evatmaster.biz.center.order.listener.BaseStringMQListener.onMessage(BaseStringMQListener.java:9)
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer$DefaultMessageListenerConcurrently.consumeMessage$original$QpHFUl6E(DefaultRocketMQListenerContainer.java:295)
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer$DefaultMessageListenerConcurrently.consumeMessage$original$QpHFUl6E$accessor$mAN1OZPY(DefaultRocketMQListenerContainer.java)
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer$DefaultMessageListenerConcurrently$auxiliary$Nka19xia.call(Unknown Source)
at org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstMethodsInter.intercept(InstMethodsInter.java:86)
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer$DefaultMessageListenerConcurrently.consumeMessage(DefaultRocketMQListenerContainer.java)
at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:417)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
--
### logger_message
consume message failed. messageExt:MessageExt [queueId=0, storeSize=747, queueOffset=97, sysFlag=0, bornTimestamp=1684410538674, bornHost=/172.30.113.163:57632, storeTimestamp=1684411178723, storeHost=/172.30.13.248:10911, msgId=AC1E0DF800002A9F0000002F2FBA358E, commitLogOffset=202664195470, bodyCRC=1155098648, reconsumeTimes=6, preparedTransactionOffset=0, toString()=Message{topic='order_to_be_paid', flag=0, properties={USERS_id=25a15e2b-72c5-4373-8ed9-143addfafd81, CONSUME_START_TIME=1684411178724, MIN_OFFSET=0, REAL_TOPIC=%RETRY%order_to_be_paid, sw8-x=0-1684410538674, ORIGIN_MESSAGE_ID=AC1E0DF800002A9F0000002F2FA36647, USERS_timestamp=1684410538674, sw8=1-NGVkNGEyNmJlZTA0NDcyOGIxYzk2MDJjMmIxZDg2MmUuNzIuMTY4NDQxMDUzODYxOTM0MDc=-NjY3MmRlMTQyMTdlNDg5YWJjY2Q1ZmNlNzQwZjlkM2QuMTA1LjE2ODQ0MTA1Mzg2MjIzMzQ0-57-Y2VudGVyOjpzdmMtYml6LWNlbnRlcg==-MTcyLjMwLjExMy4xNjM=-UE9TVDovbWVyYy9vcmRlci9jcmVhdGU=-cHJvZC1tcW5hbWVzcnYucHJvZC5zdmMuY2x1c3Rlci5sb2NhbDo5ODc2, RETRY_TOPIC=order_to_be_paid, MAX_OFFSET=98, UNIQ_KEY=AC1E71A3000109573B3B5BCCA6B20011, WAIT=false, DELAY=8, REAL_QID=0}, body=[123, 34, 111, 114, 100, 101, 114, 73, 100, 34, 58, 49, 54, 53, 57, 49, 54, 52, 49, 55, 48, 51, 54, 54, 52, 56, 56, 53, 55, 55, 44, 34, 115, 121, 115, 116, 101, 109, 84, 121, 112, 101, 34, 58, 34, 48, 48, 34, 125], transactionId='null'}]
--


maven version
rocketmq-spring-boot-starter 2.0.1
--
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.