public void shutdownRequested()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java [103:111]

• 9 lines of code
• 2 McCabe index (conditional complexity)

  public void shutdownRequested(ShutdownRequestedInput shutdownRequestedInput) {
    try {
      logger.atInfo().log("Scheduler is shutting down, checkpointing.");
      shutdownRequestedInput.checkpointer().checkpoint();
    } catch (ShutdownException | InvalidStateException e) {
      logger.atSevere().withCause(e).log(
          "Exception while checkpointing at requested shutdown. Giving up.");
    }
  }