public ConsumeOrderlyStatus consumeMessage()

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;
        }