def checkpointLastProcessedRecord()

in src/main/scala/com/gu/kinesis/RecordProcessorImpl.scala [49:60]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  def checkpointLastProcessedRecord(checkpointLogic: KinesisRecord => Unit): Unit = lock.synchronized {
    popProcessedRecords()

    lastProcessedButNotCheckpointed.foreach { kinesisRecord =>
      try {
        checkpointLogic(kinesisRecord)
        lastProcessedButNotCheckpointed = None
      } finally {
        clearCheckpointTriggers()
      }
    }
  }