Simplify ConnectionPersistenceActorTest

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
eclipse-ditto · Aug 1, 2022 · 6cdb35f · 6cdb35f
1 parent 474a9c1
commit 6cdb35f
Show file tree

Hide file tree

Showing 8 changed files with 590 additions and 1,199 deletions.
diff --git a/...se/ditto/connectivity/service/messaging/validation/DittoConnectivityCommandValidator.java b/...se/ditto/connectivity/service/messaging/validation/DittoConnectivityCommandValidator.java
@@ -66,7 +66,7 @@ public void accept(final ConnectivityCommand<?> command, final Supplier<Connecti
                             .ifPresentOrElse(connection -> {
                                         connectionValidator.validate(connection, command.getDittoHeaders(), actorSystem);
                                         propsFactory.getActorPropsForType(connection, proxyActor, connectionActor, actorSystem,
-                                                DittoHeaders.empty(), ConfigFactory.empty());
+                                                command.getDittoHeaders(), ConfigFactory.empty());
                                     },
                                     // should never happen
                                     handleNullConnection(command));

diff --git a/...va/org/eclipse/ditto/connectivity/service/messaging/ExceptionClientActorPropsFactory.java b/...va/org/eclipse/ditto/connectivity/service/messaging/ExceptionClientActorPropsFactory.java
diff --git a/.../src/test/java/org/eclipse/ditto/connectivity/service/messaging/FailingActorProvider.java b/.../src/test/java/org/eclipse/ditto/connectivity/service/messaging/FailingActorProvider.java