def sendMessage()

in src/main/scala/com/gu/octopusthrift/aws/SQS.scala [17:27]


  def sendMessage(message: JsValue) = {

    val request =
      new SendMessageRequest().withQueueUrl(config.deadLetterQueue).withMessageBody(Json.stringify(message))

    Try(sqsClient.sendMessage(request)) match {
      case Success(messageResult: SendMessageResult) =>
        logger.info(s"Message sent to dead letter queue with ID ${messageResult.getMessageId}")
      case Failure(e) => s"Dead letter sendMessage Exception: ${e.getMessage}"
    }
  }