Fix unittests

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>

connectivity/service/src/test/java/org/eclipse/ditto/connectivity/service/messaging/persistence/AlwaysFailingUpdatedConnectionTester.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright (c) 2022 Contributors to the Eclipse Foundation
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information regarding copyright ownership.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ */
+package org.eclipse.ditto.connectivity.service.messaging.persistence;
+
+import java.util.Optional;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionStage;
+
+import org.eclipse.ditto.base.model.headers.DittoHeaders;
+import org.eclipse.ditto.connectivity.model.Connection;
+import org.eclipse.ditto.connectivity.model.signals.commands.modify.TestConnectionResponse;
+
+import akka.actor.ActorSystem;
+
+public final class AlwaysFailingUpdatedConnectionTester implements UpdatedConnectionTester{
+
+    private AlwaysFailingUpdatedConnectionTester(final ActorSystem actorSystem) {}
+
+    @Override
+    public CompletionStage<Optional<TestConnectionResponse>> testConnection(final Connection updatedConnection,
+            final DittoHeaders dittoHeaders) {
+        return CompletableFuture.completedStage(Optional.empty());
+    }
+}

connectivity/service/src/test/resources/test.conf

@@ -19,6 +19,7 @@ akka.cluster.jmx.multi-mbeans-in-same-jvm = on
 akka.cluster.roles = ["thing-event-aware", "live-signal-aware", "acks-aware", "policy-announcement-aware"]
 
 ditto {
+  connection-update-tester = "org.eclipse.ditto.connectivity.service.messaging.persistence.AlwaysFailingUpdatedConnectionTester"
   mapping-strategy.implementation = "org.eclipse.ditto.connectivity.api.ConnectivityMappingStrategies"
 
   ddata {