override def send()

in src/main/scala/com/gu/salesforce/messageHandler/SqsClient.scala [22:33]

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

  override def send(queueName: String, message: String)(implicit ec: ExecutionContext): Future[Try[SendMessageResult]] = {
    val queueUrl = sqsClient.getQueueUrl(queueName).getQueueUrl

    def sendToQueue(msg: String): SendMessageResult = {
      logger.info(s"sending message to queue $queueUrl: $msg")
      val sendMessageRequest = new SendMessageRequest(queueUrl, msg)
      sqsClient.sendMessage(sendMessageRequest)
    }
    Future {
      Try(sendToQueue(message))
    }
  }