public static boolean createTopic()

in java/e2e-v4/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [58:76]

• 19 lines of code
• 4 McCabe index (conditional complexity)

    public static boolean createTopic(String nameSrvAddr, String clusterName, String topic, int queueNum, int waitTimeSec) {
        boolean createResult = false;
        try {
            mqAdminExt.createTopic(clusterName, topic, queueNum);
        } 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;
            }
        }
        return createResult;
    }