search

apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.29k stars 11.71k forks source link

rocketmq message hasnot been sent, Caused by ConcurrentModificationException #2924

Closed catalpa-tree closed 1 year ago

catalpa-tree commented 3 years ago

Use rocketMQTemplate.asyncSend to send msg; throw org.springframework.messaging.MessagingException: nested exception is java.util.ConcurrentModificationException, failedMessage=GenericMessage [payload=byte[142], headers={id=9f951e70-dbae-c369-3877-d8438f5f22bd, contentType=application/json, TAGS=sign, timestamp=1621476904559}]

rocketmq-client version is 4.4.0

image

catalpa-tree commented 3 years ago

Is not a problem will now, is the incidental question, 100 requests in 1 or 2 times, lead to the failure message is sent

duhenglucky commented 3 years ago

@catalpa-tree could you leave more information in here or submit a new issue in this repo(if you used this project instead of rocketmq-client):https://github.com/apache/rocketmq-spring

dujingsong commented 2 years ago

@duhenglucky same problem! use rocketmq-spring-boot-starter（2.1.0），broker version is 4.7.1，1 master 2 slave dleger image

github-actions[bot] commented 1 year ago

This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.

github-actions[bot] commented 1 year ago

This issue was closed because it has been inactive for 3 days since being marked as stale.