ROCKETMQ记录源码细节及疑问

1.MessageListener实现最终返回null的话,默认是RECONSUME_LATER

            if (null == status) {
                log.warn("consumeMessage return null, Group: {} Msgs: {} MQ: {}",
                    ConsumeMessageConcurrentlyService.this.consumerGroup,
                    msgs,
                    messageQueue);
                status = ConsumeConcurrentlyStatus.RECONSUME_LATER;
            }

猜你喜欢

转载自blog.csdn.net/u012210451/article/details/84133706