ozhera-log/log-manager/src/main/java/org/apache/ozhera/log/manager/common/Utils.java [162:170]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static List<String> generateCommonTagTopicName(String orgId) {
        return IntStream.range(0, COMMON_MQ_SUFFIX.size()).mapToObj(value -> {
            String suffix = COMMON_MQ_SUFFIX.get(value);
            if (StringUtils.isNotBlank(orgId)) {
                return String.format("%s_%s_%s", COMMON_MQ_PREFIX, orgId, suffix);
            }
            return String.format("%s_%s", COMMON_MQ_PREFIX, suffix);
        }).collect(Collectors.toList());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



ozhera-log/log-manager/src/main/java/org/apache/ozhera/log/manager/service/MqConfigService.java [43:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    default List<String> generateCommonTagTopicName(String orgId) {
        return IntStream.range(0, COMMON_MQ_SUFFIX.size()).mapToObj(value -> {
            String suffix = COMMON_MQ_SUFFIX.get(value);
            if (StringUtils.isNotBlank(orgId)) {
                return String.format("%s_%s_%s", COMMON_MQ_PREFIX, orgId, suffix);
            }
            return String.format("%s_%s", COMMON_MQ_PREFIX, suffix);
        }).collect(Collectors.toList());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -