mxsm commented on issue #5439:
URL: https://github.com/apache/rocketmq/issues/5439#issuecomment-1298245743
@shenmiren0002 I use rocketmq5.0 and rocketmq-spring version 2.2.2
```java
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
```
broker.conf
consume code:
```java
package com.github.mxsm.rocketmq;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;
@Service
@RocketMQMessageListener(topic = "mxsm",consumerGroup = "mxsm")
public class HelloConsume implements RocketMQListener<String> {
@Override
public void onMessage(String s) {
throw new IllegalArgumentException("test");
}
}
```
result after 16 times :
I think you can adjust broker config :
```properties
messageDelayLevel=1s 5s
```
messageDelayLevel implication you can see the document of official website.
you can check the code of 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]
