public void updateCredential()

in ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ONSClientAbstract.java [239:252]

13 lines of code
7 McCabe index (conditional complexity)


    public void updateCredential(Properties credentialProperties) {
        if (this.sessionCredentials.getOnsChannel().equals(ONSChannel.ALIYUN) &&
            (null == credentialProperties.getProperty(SessionCredentials.AccessKey)
                || "".equals(credentialProperties.getProperty(SessionCredentials.AccessKey)))) {
            throw new ONSClientException("update credential failed. please set access key.");
        }

        if (this.sessionCredentials.getOnsChannel().equals(ONSChannel.ALIYUN) &&
            (null == credentialProperties.getProperty(SessionCredentials.SecretKey)
                || "".equals(credentialProperties.getProperty(SessionCredentials.SecretKey)))) {
            throw new ONSClientException("update credential failed. please set secret key");
        }
        this.sessionCredentials.updateContent(credentialProperties);
    }