Untitled
scala
2 months ago
527 B
1
Indexable
Never
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) } )