Untitled

    val request = new ReceiveMessageRequest(queueUrl)
      .withMaxNumberOfMessages(settings.maxBatchSize)
      .withWaitTimeSeconds(settings.waitTimeSeconds)

    sqsClient.receiveMessageAsync(
      request,
      new AsyncHandler[ReceiveMessageRequest, ReceiveMessageResult] {
        override def onSuccess(request: ReceiveMessageRequest, result: ReceiveMessageResult): Unit =
          successCallback.invoke(result)

        override def onError(e: Exception): Unit =
          failureCallback.invoke(e)
      }
    )