public static ClientConfiguration createClientConfiguration()

in rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQUtil.java [147:170]

23 lines of code
7 McCabe index (conditional complexity)


    public static ClientConfiguration createClientConfiguration(String accessKey, String secretKey, String endPoints,
                                                                Duration requestTimeout, Boolean sslEnabled, String namespace) {

        SessionCredentialsProvider sessionCredentialsProvider = null;
        if (StringUtils.hasLength(accessKey) && StringUtils.hasLength(secretKey)) {
            sessionCredentialsProvider =
                    new StaticSessionCredentialsProvider(accessKey, secretKey);
        }
        ClientConfigurationBuilder clientConfigurationBuilder = ClientConfiguration.newBuilder()
                .setEndpoints(endPoints);
        if (sessionCredentialsProvider != null) {
            clientConfigurationBuilder.setCredentialProvider(sessionCredentialsProvider);
        }
        if (Objects.nonNull(requestTimeout)) {
            clientConfigurationBuilder.setRequestTimeout(requestTimeout);
        }
        if (Objects.nonNull(sslEnabled)) {
            clientConfigurationBuilder.enableSsl(sslEnabled);
        }
        if (StringUtils.hasLength(namespace)) {
            clientConfigurationBuilder.setNamespace(namespace);
        }
        return clientConfigurationBuilder.build();
    }