You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2021/10/05 07:10:29 UTC
[camel-quarkus] 02/04: Enable sqsAutoCreateDelayedQueue test
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 4a58af3a9886f2f86381c0a085a8595456747fb3
Author: James Netherton <ja...@gmail.com>
AuthorDate: Mon Oct 4 15:26:58 2021 +0100
Enable sqsAutoCreateDelayedQueue test
Fixes #3097
---
.../camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java | 2 +-
.../apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java | 6 ++----
2 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java b/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java
index f1c3021..5435ef7 100644
--- a/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java
+++ b/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsResource.java
@@ -174,7 +174,7 @@ public class Aws2SqsSnsResource {
}
@Path("/sqs/queue/autocreate/delayed/{queueName}/{delay}")
- @GET
+ @POST
@Produces(MediaType.APPLICATION_JSON)
public List<String> autoCreateDelayedQueue(@PathParam("queueName") String queueName, @PathParam("delay") String delay)
throws Exception {
diff --git a/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java b/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java
index 7f41c1b..96e766c 100644
--- a/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java
+++ b/integration-test-groups/aws2/aws2-sqs-sns/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsSnsTest.java
@@ -34,7 +34,6 @@ import org.awaitility.Awaitility;
import org.eclipse.microprofile.config.ConfigProvider;
import org.hamcrest.Matchers;
import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import static org.hamcrest.CoreMatchers.anyOf;
@@ -103,7 +102,6 @@ class Aws2SqsSnsTest {
}
@Test
- @Disabled("https://github.com/apache/camel-quarkus/issues/3097")
public void sqsAutoCreateDelayedQueue() {
final String qName = "delayQueue";
final int delay = 10;
@@ -129,7 +127,7 @@ class Aws2SqsSnsTest {
}
private void deleteQueue(String queueName) {
- RestAssured.get("/aws2-sqs-sns/sqs/delete/queue/" + queueName)
+ RestAssured.delete("/aws2-sqs-sns/sqs/delete/queue/" + queueName)
.then()
.statusCode(200);
awaitQueueDeleted(queueName);
@@ -137,7 +135,7 @@ class Aws2SqsSnsTest {
private void awaitQueueDeleted(String queueName) {
Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120, TimeUnit.SECONDS).until(
- () -> Stream.of(listQueues()).peek(System.out::println).noneMatch(url -> url.contains(queueName)));
+ () -> Stream.of(listQueues()).noneMatch(url -> url.contains(queueName)));
}
private String receiveMessageFromQueue(String queueName) {