public void initBeginPosition()

in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/position/BinlogPositionManager.java [51:71]

• 15 lines of code
• 8 McCabe index (conditional complexity)

    public void initBeginPosition() throws Exception {

        if (config.startType == null || config.startType.equals("DEFAULT")) {
            initPositionDefault();

        } else if (config.startType.equals("NEW_EVENT")) {
            initPositionFromBinlogTail();

        } else if (config.startType.equals("LAST_PROCESSED")) {
            initPositionFromMqTail();

        } else if (config.startType.equals("SPECIFIED")) {
            binlogFilename = config.binlogFilename;
            nextPosition = config.nextPosition;

        }

        if (binlogFilename == null || nextPosition == null) {
            throw new Exception("binlogFilename | nextPosition is null.");
        }
    }