mufengCc opened a new issue, #557:
URL: https://github.com/apache/rocketmq-spring/issues/557
**BUG REPORT**
1. Please describe the issue you observed:
Using the "@ RocketMQMessage Listener" annotation and specifying the
"consumeMode=ConsumeMode. ORDERLY" mode, implement the
RocketMQPushConsumerLifecycleListener interface, set the number of failed
consumption retries defaultMQPushConsumer. setMaxReconsumeTimes (3);
When consuming a message, a RuntimeException() exception was manually
thrown, and after verification, it was found that the number of retries
exceeded my set value of 3. Why is this?
2. Please tell us about your environment:
rocketmq server: v5.1.0
rocketmq-spring：v.2.2.3
3.Log and code
```
@RocketMQMessageListener(topic = "orderly-v1-topic",
consumeMode = ConsumeMode.ORDERLY,
consumerGroup = "orderly-v1-message-group")
@Slf4j
@Component
public class orderMessageConsumer implements RocketMQListener<String>,
RocketMQPushConsumerLifecycleListener {
@Override
public void onMessage(String mess) {
log.info("顺序消息:" + mess);
throw new RuntimeException("处理失败:" + System.currentTimeMillis());
}
@Override
public void prepareStart(DefaultMQPushConsumer defaultMQPushConsumer) {
// Set the maximum retry count for consumption and verify if this
parameter is valid in sequential consumption mode
defaultMQPushConsumer.setMaxReconsumeTimes(3);
}
}
```
```
2023-04-26 11:26:55.028 INFO 24232 --- [MessageThread_1]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:26:56.041 INFO 24232 --- [MessageThread_2]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:26:57.050 INFO 24232 --- [MessageThread_3]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:26:58.058 INFO 24232 --- [MessageThread_4]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:28:58.090 INFO 24232 --- [MessageThread_5]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:30:58.176 INFO 24232 --- [MessageThread_6]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:32:58.239 INFO 24232 --- [MessageThread_7]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:34:58.329 INFO 24232 --- [MessageThread_8]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:36:58.407 INFO 24232 --- [MessageThread_9]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:38:58.458 INFO 24232 --- [essageThread_10]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:40:58.551 INFO 24232 --- [essageThread_11]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:42:58.649 INFO 24232 --- [essageThread_12]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:44:58.730 INFO 24232 --- [essageThread_13]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:46:58.803 INFO 24232 --- [essageThread_14]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:48:58.905 INFO 24232 --- [essageThread_15]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:50:59.002 INFO 24232 --- [essageThread_16]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:52:59.074 INFO 24232 --- [essageThread_17]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:54:59.086 INFO 24232 --- [essageThread_18]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:56:59.119 INFO 24232 --- [essageThread_19]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 11:58:59.164 INFO 24232 --- [essageThread_20]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 12:00:59.206 INFO 24232 --- [MessageThread_1]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 12:02:59.295 INFO 24232 --- [MessageThread_2]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
2023-04-26 12:04:59.377 INFO 24232 --- [MessageThread_3]
c.m.springtest.mq.orderMessageConsumer : 顺序消息:orderly message
...
```
5. Other information (e.g. detailed explanation, logs, related issues,
suggestions how to fix, etc):
```
/**
* Max re-consume times.
* In concurrently mode, -1 means 16;
* In orderly mode, -1 means Integer.MAX_VALUE.
*
* If messages are re-consumed more than {@link #maxReconsumeTimes}
before success.
*/
private int maxReconsumeTimes = -1;
```
Does not match the description? Please tell me what caused it. Thank you
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
