写了一个rocketmq消费者, 配置了消费失败最大重试次数, 但是没有生效,仍然不断的重复消费,是我的配置有问题吗?
@Component
@RocketMQMessageListener(maxReconsumeTimes = 1, topic = "${rocketmq.consumer.topic}",
consumerGroup = "default",
selectorExpression = "*")
public class RelationshipListener implements RocketMQListener<String> {
private static Logger log = LoggerFactory.getLogger(RelationshipListener.class);
@Autowired
UserSwitchService userSwitchService;
@Override
public void onMessage(String msg) {
log.info("listening rocketMq message start: {}" + msg);
try {
consume(msg);
log.info("listening rocketMq message end");
} catch (Exception e) {
throw new RuntimeException("consumer fail");
}
}