private PulsarAdmin createPulsarAdmin()

in src/main/java/org/apache/pulsar/manager/service/impl/PulsarAdminServiceImpl.java [162:187]

26 lines of code
5 McCabe index (conditional complexity)


    private PulsarAdmin createPulsarAdmin(String url, String token) {
        try {
            log.info("Create Pulsar Admin instance. url={}, authPlugin={}, authParams={}, tlsAllowInsecureConnection={}, tlsTrustCertsFilePath={}, tlsEnableHostnameVerification={}",
                    url, authPlugin, authParams, tlsAllowInsecureConnection, tlsTrustCertsFilePath, tlsEnableHostnameVerification);
            PulsarAdminBuilder pulsarAdminBuilder = PulsarAdmin.builder();
            pulsarAdminBuilder.serviceHttpUrl(url);
            if (null == token) {
                token = getEnvironmentToken(url);
            }
            if (StringUtils.isNotBlank(token)) {
                pulsarAdminBuilder.authentication(AuthenticationFactory.token(token));
            } else if (StringUtils.isNotBlank(pulsarJwtToken)) {
                pulsarAdminBuilder.authentication(AuthenticationFactory.token(pulsarJwtToken));
            } else {
                pulsarAdminBuilder.authentication(authPlugin, authParams);
            }
            pulsarAdminBuilder.allowTlsInsecureConnection(tlsAllowInsecureConnection);
            pulsarAdminBuilder.tlsTrustCertsFilePath(tlsTrustCertsFilePath);
            pulsarAdminBuilder.enableTlsHostnameVerification(tlsEnableHostnameVerification);
            return pulsarAdminBuilder.build();
        } catch (PulsarClientException e) {
            PulsarAdminOperationException pulsarAdminOperationException = new PulsarAdminOperationException("Failed to create Pulsar Admin instance.");
            log.error(pulsarAdminOperationException.getMessage(), e);
            throw pulsarAdminOperationException;
        }
    }