Mensageria com Amazon SQS | Alura Cursos Online

 String url = "https://sqs.us-east-1.amazonaws.com/403828569551/caelum-queue-jms"; AmazonSQSClient sqsClient = new AmazonSQSClient(awsCredentials); sqsClient.sendMessage(new SendMessageRequest() .withQueueUrl(url).withMessageBody("Texto da MSG."));

 ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest("https://sqs.us-east-1.amazonaws.com/403828569551/caelum-queue-jms"); AmazonSQSClient sqsClient = new AmazonSQSClient(awsCredentials); List<Message> messages = sqsClient.receiveMessage(receiveMessageRequest).getMessages(); for (Message message : messages) { System.out.println("MSG"); System.out.println("MsgID: " + message.getMessageId()); System.out.println("Identificador Único MSG: " + message.getReceiptHandle()); System.out.println("MD5 do Corpo da MSG: " + message.getMD5OfBody()); System.out.println("Corpo: " + message.getBody()); for (Entry<String, String> entry : message.getAttributes().entrySet()) { System.out.println("Atributos"); System.out.println("Nome: " + entry.getKey()); System.out.println("Valor: " + entry.getValue()); } }

 String url = "https://sqs.us-east-1.amazonaws.com/403828569551/caelum-queue-jms"; AmazonSQSClient sqsClient = new AmazonSQSClient(awsCredentials); ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(url); List<Message> messages = sqsClient.receiveMessage(receiveMessageRequest).getMessages(); System.out.println("Deletando a MSG.\\n" + messages.get(0).getBody()); String messageReceiptHandle = messages.get(0).getReceiptHandle(); sqsClient.deleteMessage(new DeleteMessageRequest().withQueueUrl(url).withReceiptHandle(messageReceiptHandle));

Mensageria com Amazon SQS | Alura Cursos Online