override def shutdownRequested()

in src/main/scala/com/gu/kinesis/RecordProcessorImpl.scala [149:158]

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

  override def shutdownRequested(shutdownRequestedInput: ShutdownRequestedInput): Unit = {
    log.info(s"Shutdown requested: $shardId")
    shutdown(
      ShutdownInput
        .builder()
        .checkpointer(shutdownRequestedInput.checkpointer())
        .shutdownReason(ShutdownReason.REQUESTED)
        .build()
    )
  }