OpenTelemetry: improve stability of PeriodicAsyncMeasurementTest #2

see d539000
eclipse-scout · Jun 7, 2024 · 34a304b · 34a304b
1 parent 97f8d78
commit 34a304b
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...c/test/java/org/eclipse/scout/rt/platform/opentelemetry/PeriodicAsyncMeasurementTest.java b/...c/test/java/org/eclipse/scout/rt/platform/opentelemetry/PeriodicAsyncMeasurementTest.java
@@ -220,7 +220,10 @@ public void testActiveOnThisNode() throws Exception {
 
     final long asyncObservationInterval = 100;
     Callable<Long> callable = mockCallable();
-    Mockito.when(callable.call()).thenReturn(111L);
+    Mockito.when(callable.call()).then(invocation -> {
+      Thread.sleep(3); // simulate "db access"
+      return 111L;
+    });
     AtomicBoolean activeOnThisNode = new AtomicBoolean(false);
     try (PeriodicAsyncMeasurement<Long> asyncMeasurement = new PeriodicAsyncMeasurement<>("testActiveOnThisNode", callable, () -> RunContexts.empty(), () -> activeOnThisNode.get(), asyncObservationInterval)) {
 
@@ -238,7 +241,6 @@ public void testActiveOnThisNode() throws Exception {
       assertNull(asyncMeasurement.getAndNext());
       assertAsyncJobTrigger(callable, 0);
 
-      Thread.sleep(20);
       activeOnThisNode.set(Boolean.TRUE);
 
       // forth observation --> no measurement, but trigger async job