public TopicList fetchAllTopicList()

in src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java [97:121]

• 25 lines of code
• 6 McCabe index (conditional complexity)

    public TopicList fetchAllTopicList(boolean skipSysProcess, boolean skipRetryAndDlq) {
        try {
            TopicList allTopics = mqAdminExt.fetchAllTopicList();
            TopicList sysTopics = getSystemTopicList();
            Set<String> topics =
                    allTopics.getTopicList().stream().map(topic -> {
                        if (!skipSysProcess && sysTopics.getTopicList().contains(topic)) {
                            topic = String.format("%s%s", "%SYS%", topic);
                        }
                        return topic;
                    }).filter(topic -> {
                        if (skipRetryAndDlq) {
                            return !(topic.startsWith(MixAll.RETRY_GROUP_TOPIC_PREFIX)
                                    || topic.startsWith(MixAll.DLQ_GROUP_TOPIC_PREFIX));
                        }
                        return true;
                    }).collect(Collectors.toSet());
            allTopics.getTopicList().clear();
            allTopics.getTopicList().addAll(topics);
            return allTopics;
        } catch (Exception e) {
            Throwables.throwIfUnchecked(e);
            throw new RuntimeException(e);
        }
    }