在Akka streams中确认SQS消息的正确方式是什么

import akka.Done
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.alpakka.sqs.scaladsl.SqsSource
import akka.stream.scaladsl.Sink
import com.amazonaws.services.sqs.AmazonSQSAsync
import com.amazonaws.services.sqs.AmazonSQSAsyncClientBuilder
import com.amazonaws.services.sqs.model.Message

import scala.concurrent.{ExecutionContext, Future}

object SQSConsumer {
  implicit val system: ActorSystem = ActorSystem("sqs-consumer")
  implicit val materializer: ActorMaterializer = ActorMaterializer()
  implicit val executionContext: ExecutionContext = system.dispatcher

  val sqsClient: AmazonSQSAsync = AmazonSQSAsyncClientBuilder.defaultClient()

  def main(args: Array[String]): Unit = {
    val queueUrl = "YOUR_SQS_QUEUE_URL"

    val done: Future[Done] =
      SqsSource(queueUrl)
        .map(handleMessage)
        .runWith(Sink.ignore)

    done.onComplete(_ => system.terminate())
  }

  def handleMessage(message: Message): Unit = {
    // 处理消息的逻辑
    println(s"Received message: ${message.getBody}")
    // 确认消息已处理
    sqsClient.deleteMessage("YOUR_QUEUE_URL", message.getReceiptHandle)
  }
}