in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java [212:223]
public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgList,
ConsumeOrderlyContext context) {
try {
if (CollectionUtils.isNotEmpty(msgList)) {
msgList.forEach(this::consumeMessage);
}
} catch (Exception e) {
log.error("consume message exception, reconsume later");
return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
}
return ConsumeOrderlyStatus.SUCCESS;
}