(camel-quarkus) branch 3.8.x updated: [Azure] Fix flaky storage queue crud test

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch 3.8.x
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/3.8.x by this push:
     new 866b095d0e [Azure] Fix flaky storage queue crud test
866b095d0e is described below

commit 866b095d0eb221b4a2d6a3f680896633f762cf6e
Author: Andrej Vano <av...@redhat.com>
AuthorDate: Wed Jun 12 12:23:36 2024 +0200

    [Azure] Fix flaky storage queue crud test
---
 .../azure/storage/queue/it/AzureStorageQueueResource.java         | 6 ++++--
 .../component/azure/storage/queue/it/AzureStorageQueueTest.java   | 8 ++++----
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/integration-test-groups/azure/azure-storage-queue/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueResource.java
 
b/integration-test-groups/azure/azure-storage-queue/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueResource.java
index c97312cafc..9b2c4f9461 100644
--- 
a/integration-test-groups/azure/azure-storage-queue/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueResource.java
+++ 
b/integration-test-groups/azure/azure-storage-queue/src/main/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueResource.java
@@ -157,7 +157,8 @@ public class AzureStorageQueueResource {
         return Response.noContent().build();
     }
 
-    @Path("/queue/delete/{id}/{popReceipt}")
+    // popReceipt may contain a slash, so override its regex to "everything"
+    @Path("/queue/delete/{id}/{popReceipt:.*}")
     @DELETE
     public Response deleteMessageById(@PathParam("id") String id, 
@PathParam("popReceipt") String popReceipt) throws Exception {
         var headers = new HashMap<String, Object>();
@@ -170,7 +171,8 @@ public class AzureStorageQueueResource {
         return Response.noContent().build();
     }
 
-    @Path("/queue/update/{id}/{popReceipt}")
+    // popReceipt may contain a slash, so override its regex to "everything"
+    @Path("/queue/update/{id}/{popReceipt:.*}")
     @POST
     @Consumes(MediaType.TEXT_PLAIN)
     public Response addMessage(@PathParam("id") String id, 
@PathParam("popReceipt") String popReceipt, String message)
diff --git 
a/integration-test-groups/azure/azure-storage-queue/src/test/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueTest.java
 
b/integration-test-groups/azure/azure-storage-queue/src/test/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueTest.java
index a03217b707..4552494f59 100644
--- 
a/integration-test-groups/azure/azure-storage-queue/src/test/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueTest.java
+++ 
b/integration-test-groups/azure/azure-storage-queue/src/test/java/org/apache/camel/quarkus/component/azure/storage/queue/it/AzureStorageQueueTest.java
@@ -50,8 +50,8 @@ class AzureStorageQueueTest {
                     .then()
                     .statusCode(201);
 
-            // create 2 messages
-            for (int i = 1; i < 2; i++) {
+            // create messages
+            for (int i = 1; i < 3; i++) {
                 addMessage(message + i);
             }
 
@@ -61,9 +61,9 @@ class AzureStorageQueueTest {
                     .statusCode(200)
                     .body(is(message + "1"));
 
-            // Read 2 messages
+            // Read messages
             List<LinkedHashMap<String, String>> response = null;
-            for (int i = 1; i < 2; i++) {
+            for (int i = 1; i < 3; i++) {
                 response = readMessage();
                 assertNotNull(response);
                 assertEquals(1, response.size());