private int calcDelaySec()

in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/ErrorHandler.java [82:98]

• 17 lines of code
• 6 McCabe index (conditional complexity)

    private int calcDelaySec(int retryTimes, PushRetryStrategyEnum pushRetryStrategyEnum) {
        switch (pushRetryStrategyEnum) {
            case BACKOFF_RETRY:
                if (retryTimes >= pushRetryStrategyEnum.getRetryTimes()) {
                    return -1;
                }
                return 10;
            case EXPONENTIAL_DECAY_RETRY:
                if (retryTimes >= pushRetryStrategyEnum.getRetryTimes()) {
                    return -1;
                }
                int pow = (int) Math.pow(2, 3 + retryTimes);
                return (pow > 512 ? 512 : pow);
            default:
                return -1;
        }
    }