public MessagePage queryDlqMessageByPage()

in src/main/java/org/apache/rocketmq/dashboard/service/impl/DlqMessageServiceImpl.java [53:73]

• 20 lines of code
• 5 McCabe index (conditional complexity)

    public MessagePage queryDlqMessageByPage(MessageQuery query) {
        List<MessageView> messageViews = new ArrayList<>();
        PageRequest page = PageRequest.of(query.getPageNum(), query.getPageSize());
        String topic = query.getTopic();
        try {
            mqAdminExt.examineTopicRouteInfo(topic);
        } catch (MQClientException e) {
            // If the %DLQ%Group does not exist, the message returns null
            if (topic.startsWith(MixAll.DLQ_GROUP_TOPIC_PREFIX)
                && e.getResponseCode() == ResponseCode.TOPIC_NOT_EXIST) {
                return new MessagePage(new PageImpl<>(messageViews, page, 0), query.getTaskId());
            } else {
                Throwables.throwIfUnchecked(e);
                throw new RuntimeException(e);
            }
        } catch (Exception e) {
            Throwables.throwIfUnchecked(e);
            throw new RuntimeException(e);
        }
        return messageService.queryMessageByPage(query);
    }