public static boolean createTopic()

in java/e2e-spring/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [85:107]

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

    public static boolean createTopic(String clusterName, String topic, int queueNum, Map<String, String> attributes,
        int waitTimeSec) {
        boolean createResult = false;
        try {
            mqAdminExt.createTopic(clusterName, topic, queueNum, attributes);
        } catch (Exception e) {
            e.printStackTrace();
        }
        long startTime = System.currentTimeMillis();
        while (!createResult) {
            createResult = checkTopicExist(mqAdminExt, topic);
            if (System.currentTimeMillis() - startTime < waitTimeSec * 1000) {
                TestUtils.waitForMoment(100);
            } else {
                log.error(String.format("timeout,but create topic[%s] failed!", topic));
                break;
            }
        }
        if (createResult) {
            log.info("create topic:{} success", topic);
        }
        return createResult;
    }