aldettinger commented on a change in pull request #3074:
URL: https://github.com/apache/camel-quarkus/pull/3074#discussion_r704419652
##########
File path:
integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java
##########
@@ -40,28 +45,157 @@
@Test
public void sqs() {
- final Config config = ConfigProvider.getConfig();
- final String queueName = config.getValue("aws-sqs.queue-name",
String.class);
+ final String queueName = getPredefinedQueueName();
- String[] queues = RestAssured.get("/aws2-sqs-sns/sqs/queues")
+ final String[] queues = listQueues();
+ Assertions.assertTrue(Stream.of(queues).anyMatch(url ->
url.contains(queueName)));
+
+ final String msg = sendSingleMessageToQueue(queueName);
+ awaitMessageFromQueue(msg, queueName);
+ }
+
+ private String[] listQueues() {
+ return RestAssured.get("/aws2-sqs-sns/sqs/queues")
.then()
.statusCode(200)
.extract()
.body().as(String[].class);
- Assertions.assertTrue(Stream.of(queues).anyMatch(url ->
url.contains(queueName)));
+ }
+
+ @Test
+ public void sqsDeleteMessage() {
+ final String qName = getPredefinedQueueName();
+ final String msg = sendSingleMessageToQueue(qName);
+ final String receipt = receiveReceiptOfMessageFromQueue(qName);
+ deleteMessageFromQueue(qName, receipt);
+ Assertions.assertNotEquals(receiveMessageFromQueue(qName), msg);
+ }
+
+ private String getPredefinedQueueName() {
+ return ConfigProvider.getConfig().getValue("aws-sqs.queue-name",
String.class);
+ }
+ private String sendSingleMessageToQueue(String queueName) {
Review comment:
It's good idea to explicit SingleMessage vs BatchMessage :+1:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
