def publish()

in src/main/scala/com/gu/octopusthrift/aws/Kinesis.scala [17:36]

• 16 lines of code
• 3 McCabe index (conditional complexity)

  def publish(message: Array[Byte]): Unit = {
    val partitionKey = UUID.randomUUID().toString

    logger.info("Publishing message to kinesis")

    val data = ByteBuffer.wrap(message)

    val request = new PutRecordRequest()
      .withStreamName(config.thriftStreamName)
      .withPartitionKey(partitionKey)
      .withData(data)

    try {
      val result = kinesisClient.putRecord(request)
      logger.info(s"Published kinesis message: $result")
    } catch {
      case e: Exception =>
        logger.error(s"kinesis putRecord exception message: ${e.getMessage}")
    }
  }