Example SQS interactions with AWS-Wrap

example.scala

import com.amazonaws.auth.DefaultAWSCredentialsProviderChain
import com.amazonaws.services.sqs.AmazonSQSAsyncClient
import com.amazonaws.services.sqs.model.{ReceiveMessageResult, SendMessageResult}
import com.github.dwhjames.awswrap.sqs.AmazonSQSScalaClient

import scala.collection.JavaConverters._
import scala.concurrent.{Await, Future}
import scala.language.postfixOps
import scala.concurrent.duration._
implicit val ec = scala.concurrent.ExecutionContext.global
implicit val javaSQSClient = new AmazonSQSAsyncClient(new DefaultAWSCredentialsProviderChain())

val sqsClient: AmazonSQSScalaClient = new AmazonSQSScalaClient(javaSQSClient, ec)
val queueUrl = "https://sqs.us-east-1.amazonaws.com/122324/helloq"

// you might want to batch-send messages
val sendResult: Future[SendMessageResult] = sqsClient.sendMessage(queueUrl, "hello!")
Await.result(sendResult, 10 seconds)
sendResult foreach println

val receiveResult: ReceiveMessageResult = sqsClient.client.receiveMessage(queueUrl)
println(receiveResult)

val batchEntries = receiveResult
  .getMessages
  .asScala
  .map(message => (message.getMessageId, message.getReceiptHandle))

val deleteResult = sqsClient.deleteMessageBatch(queueUrl, batchEntries)
deleteResult.foreach(println)