(camel-quarkus) branch main updated: fixes #7317 Longer interval for azureServiceBus.scheduled

[jamesnetherton]

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


The following commit(s) were added to refs/heads/main by this push:
     new 2d1c89b8e5 fixes #7317 Longer interval for azureServiceBus.scheduled
2d1c89b8e5 is described below

commit 2d1c89b8e568744ec681acef5ce5efb9335789b4
Author: JiriOndrusek <ondrusek.j...@gmail.com>
AuthorDate: Tue Apr 29 16:14:14 2025 +0200

    fixes #7317 Longer interval for azureServiceBus.scheduled
---
 .../component/azure/servicebus/it/AzureServiceBusTest.java    | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git 
a/integration-test-groups/azure/azure-servicebus/src/test/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusTest.java
 
b/integration-test-groups/azure/azure-servicebus/src/test/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusTest.java
index 1634c3deb3..6660ebbfc2 100644
--- 
a/integration-test-groups/azure/azure-servicebus/src/test/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusTest.java
+++ 
b/integration-test-groups/azure/azure-servicebus/src/test/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusTest.java
@@ -264,9 +264,9 @@ class AzureServiceBusTest {
                     .then()
                     .statusCode(204);
 
-            // Schedule message for 10 seconds in the future
+            // Schedule message for 15 seconds in the future
             long scheduledEnqueueTime = Instant.now()
-                    .plus(Duration.of(10, ChronoUnit.SECONDS))
+                    .plus(Duration.of(15, ChronoUnit.SECONDS))
                     .toEpochMilli();
 
             RestAssured.given()
@@ -279,7 +279,9 @@ class AzureServiceBusTest {
                     .then()
                     .statusCode(201);
 
-            while (Instant.now().toEpochMilli() < scheduledEnqueueTime) {
+            //we are checking that there is no message in the next 10 seconds.
+            //we should rather avoid checking the message near the scheduled 
time, because process can be delayed and receives the message
+            while (Instant.now().toEpochMilli() < (scheduledEnqueueTime - 
5000)) {
                 // No message should be received before the scheduled time
                 RestAssured.given()
                         .queryParam("endpointUri", 
"mock:servicebus-queue-scheduled-consumer-results")
@@ -288,7 +290,8 @@ class AzureServiceBusTest {
                         .statusCode(200)
                         .body("size()", is(0));
                 try {
-                    Thread.sleep(250);
+                    //wait those 5 seconds, we were not checking
+                    Thread.sleep(5250);
                 } catch (InterruptedException e) {
                     Thread.currentThread().interrupt();
                 }