public void sendInactiveDatasetNotification()

in src/main/java/com/google/gcs/sdrs/service/worker/rule/impl/StsRuleExecutor.java [858:882]

24 lines of code
3 McCabe index (conditional complexity)


  public void sendInactiveDatasetNotification(
      String projectId,
      String bucket,
      List<String> prefixList,
      Instant inactiveAt,
      String correlationId) {

    for (String prefix : prefixList) {
      InactiveDatasetMessage msg = new InactiveDatasetMessage();
      msg.setCorrelationId(correlationId);
      msg.setInactiveAt(inactiveAt);
      msg.setProjectId(projectId);
      msg.setTrigger(correlationId);
      msg.setDeletedDirectoryUri(
          ValidationConstants.STORAGE_PREFIX
              + bucket
              + ValidationConstants.STORAGE_SEPARATOR
              + prefix);
      try {
        PubSubMessageQueueManagerImpl.getInstance().sendInactiveDatasetMessage(msg);
      } catch (IOException e) {
        logger.error(String.format("Error sending delete notification. %s", e.getMessage()), e);
      }
    }
  }