public void shardEnded()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java [93:100]

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

  public void shardEnded(ShardEndedInput shardEndedInput) {
    try {
      logger.atInfo().log("Reached shard end checkpointing.");
      shardEndedInput.checkpointer().checkpoint();
    } catch (ShutdownException | InvalidStateException e) {
      logger.atSevere().withCause(e).log("Exception while checkpointing at shard end. Giving up.");
    }
  }