fixed unit test

Author: thjaeckle

connectivity/service/pom.xml

@@ -175,6 +175,11 @@ jmh-generator-annprocess). jmh-generator-annprocess overwrites the whole META-IN
         </dependency>
 
         <!-- ### Testing ### -->
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.openjdk.jmh</groupId>
             <artifactId>jmh-generator-annprocess</artifactId>

connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorActorTest.java

@@ -14,12 +14,17 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+import java.time.Duration;
 import java.time.Instant;
 import java.util.Collection;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 
+import org.apache.pekko.actor.ActorRef;
+import org.apache.pekko.actor.Props;
+import org.apache.pekko.testkit.TestProbe;
+import org.apache.pekko.testkit.javadsl.TestKit;
 import org.eclipse.ditto.base.model.acks.AcknowledgementLabel;
 import org.eclipse.ditto.base.model.acks.AcknowledgementRequest;
 import org.eclipse.ditto.base.model.auth.AuthorizationContext;
@@ -58,11 +63,6 @@
 import org.junit.Test;
 import org.junit.runners.MethodSorters;
 
-import org.apache.pekko.actor.ActorRef;
-import org.apache.pekko.actor.Props;
-import org.apache.pekko.testkit.TestProbe;
-import org.apache.pekko.testkit.javadsl.TestKit;
-
 /**
  * Tests in addition to {@link MessageMappingProcessorActorTest}
  * for {@link OutboundMappingProcessorActor} only.
@@ -144,7 +144,7 @@ public void eventsWithFailedEnrichmentIssueFailedAcks() {
             underTest.tell(outboundSignal, getRef());
             proxyActorProbe.expectMsgClass(RetrieveThing.class);
 
-            final Acknowledgements acks = expectMsgClass(Acknowledgements.class);
+            final Acknowledgements acks = expectMsgClass(Duration.ofSeconds(5), Acknowledgements.class);
             final List<String> fackLabels = acks.getFailedAcknowledgements()
                     .stream()
                     .map(ack -> ack.getLabel().toString())

internal/utils/cache-loaders/src/main/java/org/eclipse/ditto/internal/utils/cacheloaders/AskWithRetry.java

@@ -18,6 +18,7 @@
 import java.util.Optional;
 import java.util.concurrent.Callable;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionException;
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.Executor;
 import java.util.function.BiFunction;
@@ -340,12 +341,15 @@ private static <A> BiFunction<AskResult<A>, Throwable, A> handleRetryResult(
 
         return (askResult, throwable) -> {
             if (null != throwable) {
-                final Throwable cause;
-                if (throwable instanceof UnknownAskRuntimeException) {
-                    cause = throwable.getCause();
+                Throwable cause;
+                if (throwable instanceof CompletionException ce) {
+                    cause = ce.getCause();
                 } else {
                     cause = throwable;
                 }
+                if (cause instanceof UnknownAskRuntimeException) {
+                    cause = cause.getCause();
+                }
                 throw DittoRuntimeException.asDittoRuntimeException(cause,
                         t -> {
                             final DittoRuntimeExceptionBuilder<AskException> exceptionBuilder =