test_class.declarator: client
test_class.modifier: private
test_class.original_string: private NiFiRegistryClient client;
test_class.type: NiFiRegistryClient
test_class.var_name: client
test_class.declarator: bucketClient
test_class.modifier: private
test_class.original_string: private BucketClient bucketClient;
test_class.type: BucketClient
test_class.var_name: bucketClient
test_class.declarator: REGISTRY_URL = "http://localhost:18080"
test_class.modifier: private static final
test_class.original_string: private static final String REGISTRY_URL = "http://localhost:18080";
test_class.type: String
test_class.var_name: REGISTRY_URL
test_class.declarator: BUCKET_ID = UUID.randomUUID().toString()
test_class.modifier: private static final
test_class.original_string: private static final String BUCKET_ID = UUID.randomUUID().toString();
test_class.type: String
test_class.var_name: BUCKET_ID
test_class.declarator: BUCKET_NAME = "Test Bucket"
test_class.modifier: private static final
test_class.original_string: private static final String BUCKET_NAME = "Test Bucket";
test_class.type: String
test_class.var_name: BUCKET_NAME
test_class.declarator: noNameBucket
test_class.modifier: private
test_class.original_string: private Bucket noNameBucket;
test_class.type: Bucket
test_class.var_name: noNameBucket
test_class.declarator: nonMatchingBucket
test_class.modifier: private
test_class.original_string: private Bucket nonMatchingBucket;
test_class.type: Bucket
test_class.var_name: nonMatchingBucket
test_class.declarator: matchingBucket
test_class.modifier: private
test_class.original_string: private Bucket matchingBucket;
test_class.type: Bucket
test_class.var_name: matchingBucket
test_class.file: efm/efm-c2-protocol/efm-c2-protocol-framework/src/test/java/com/cloudera/cem/efm/service/flow/client/TestC2NiFiRegistryClient.java
test_class.identifier: TestC2NiFiRegistryClient
test_case.body: @Test
      public void testResolveBucketIdWhenIdIsSet() throws Exception {
          C2NiFiRegistryClient client = createC2NiFiRegistryClient(BUCKET_ID, null);
  
          assertEquals(BUCKET_ID, client.resolveNiFiRegistryBucketId().get());
      }
test_case.class_method_signature: TestC2NiFiRegistryClient.testResolveBucketIdWhenIdIsSet()
test_case.full_signature: @Test public void testResolveBucketIdWhenIdIsSet()
test_case.identifier: testResolveBucketIdWhenIdIsSet
test_case.invocations: createC2NiFiRegistryClient assertEquals get resolveNiFiRegistryBucketId
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testResolveBucketIdWhenIdIsSet()
focal_class.declarator: logger = LoggerFactory.getLogger(C2NiFiRegistryClient.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger logger = LoggerFactory.getLogger(C2NiFiRegistryClient.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: registryUrl
focal_class.modifier: private final
focal_class.original_string: private final String registryUrl;
focal_class.type: String
focal_class.var_name: registryUrl
focal_class.declarator: registryBucketId
focal_class.modifier: private final
focal_class.original_string: private final String registryBucketId;
focal_class.type: String
focal_class.var_name: registryBucketId
focal_class.declarator: registryBucketName
focal_class.modifier: private final
focal_class.original_string: private final String registryBucketName;
focal_class.type: String
focal_class.var_name: registryBucketName
focal_class.declarator: client
focal_class.modifier: private final
focal_class.original_string: private final NiFiRegistryClient client;
focal_class.type: NiFiRegistryClient
focal_class.var_name: client
focal_class.file: efm/efm-c2-protocol/efm-c2-protocol-framework/src/main/java/com/cloudera/cem/efm/service/flow/client/C2NiFiRegistryClient.java
focal_class.identifier: C2NiFiRegistryClient
focal_class.class_method_signature: C2NiFiRegistryClient.C2NiFiRegistryClient(
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties)
focal_class.full_signature: @Autowired public  C2NiFiRegistryClient(
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties)
focal_class.identifier: C2NiFiRegistryClient
focal_class.modifiers: @Autowired public
focal_class.parameters: (
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties)
focal_class.signature:  C2NiFiRegistryClient(
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties)
focal_class.class_method_signature: C2NiFiRegistryClient.C2NiFiRegistryClient(
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties,
              final NiFiRegistryClient client)
focal_class.full_signature:   C2NiFiRegistryClient(
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties,
              final NiFiRegistryClient client)
focal_class.identifier: C2NiFiRegistryClient
focal_class.parameters: (
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties,
              final NiFiRegistryClient client)
focal_class.signature:  C2NiFiRegistryClient(
              final NifiRegistryProperties nifiRegistryProperties,
              final ServerProperties serverProperties,
              final NiFiRegistryClient client)
focal_class.class_method_signature: C2NiFiRegistryClient.getNiFiRegistryUrl()
focal_class.full_signature: public String getNiFiRegistryUrl()
focal_class.identifier: getNiFiRegistryUrl
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getNiFiRegistryUrl()
focal_class.class_method_signature: C2NiFiRegistryClient.getNiFiRegistryBucketId()
focal_class.full_signature: public Optional<String> getNiFiRegistryBucketId()
focal_class.identifier: getNiFiRegistryBucketId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Optional<String>
focal_class.signature: Optional<String> getNiFiRegistryBucketId()
focal_class.class_method_signature: C2NiFiRegistryClient.getNiFiRegistryBucketName()
focal_class.full_signature: public Optional<String> getNiFiRegistryBucketName()
focal_class.identifier: getNiFiRegistryBucketName
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Optional<String>
focal_class.signature: Optional<String> getNiFiRegistryBucketName()
focal_class.class_method_signature: C2NiFiRegistryClient.resolveNiFiRegistryBucketId()
focal_class.full_signature: public Optional<String> resolveNiFiRegistryBucketId()
focal_class.identifier: resolveNiFiRegistryBucketId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Optional<String>
focal_class.signature: Optional<String> resolveNiFiRegistryBucketId()
focal_class.class_method_signature: C2NiFiRegistryClient.getClient()
focal_class.full_signature: public NiFiRegistryClient getClient()
focal_class.identifier: getClient
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: NiFiRegistryClient
focal_class.signature: NiFiRegistryClient getClient()
focal_class.class_method_signature: C2NiFiRegistryClient.getBucketIdByName()
focal_class.full_signature: private Optional<String> getBucketIdByName()
focal_class.identifier: getBucketIdByName
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Optional<String>
focal_class.signature: Optional<String> getBucketIdByName()
focal_method.body: public Optional<String> resolveNiFiRegistryBucketId() throws NiFiRegistryException, IOException {
          if (registryBucketId != null) {
              logger.debug("Using configured bucketId '{}'", registryBucketId);
              return Optional.of(registryBucketId);
          }
          Optional<String> bucketIdForName = getBucketIdByName();
          if (bucketIdForName.isPresent()) {
              logger.debug("Resolved bucketId={} for bucketName={}", bucketIdForName.get(), registryBucketName);
          } else {
              logger.debug("Could not determine bucketId. Bucket named '{}' not found.", registryBucketName);
          }
          return bucketIdForName;
      }
focal_method.class_method_signature: C2NiFiRegistryClient.resolveNiFiRegistryBucketId()
focal_method.full_signature: public Optional<String> resolveNiFiRegistryBucketId()
focal_method.identifier: resolveNiFiRegistryBucketId
focal_method.invocations: debug of getBucketIdByName isPresent debug get debug
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: Optional<String>
focal_method.signature: Optional<String> resolveNiFiRegistryBucketId()