private Pubsub createClient()

in hive-metastore-listener/src/main/java/com/google/datacatalog_connectors/hive/metastore/gateways/PubSubWrapper.java [47:67]

16 lines of code
3 McCabe index (conditional complexity)


    private Pubsub createClient(){
        try {
            HttpTransport transport = GoogleNetHttpTransport.newTrustedTransport();
            GoogleCredential credential = GoogleCredential.getApplicationDefault(transport,
                JSON_FACTORY);

            if (credential.createScopedRequired()) {
                credential = credential.createScoped(PubsubScopes.all());
            }
            // Please use custom HttpRequestInitializer for automatic retry upon failures.
            //        HttpRequestInitializer initializer =
            //        new RetryHttpInitializerWrapper(credential);
            return pubsub = new Pubsub.Builder(transport, JSON_FACTORY, credential)
                    .setApplicationName("hiveMetastoreHook")
                    .build();
        } catch (Exception e) {
            log.error("Exception creating Pub/Sub instance: ", e);
            throw new RuntimeException(e);
        }

    }