public TopicList fetchAllTopicList()

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

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