def shardEnded()

in src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala [83:86]

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

  def shardEnded(shardEndedInput: ShardEndedInput): Unit = {
    logger.info(s"Shutdown event processor for shard $shardId because the shard ended")
    shutdown(ShutdownReason.SHARD_END)
  }