rocketmq 配置 maxReconsumeTimes 不生效?

新手上路,请多包涵

写了一个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");
        }

    }
阅读 712
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题
宣传栏