connector fix executeTask logic error (#1197)

it-at-m · Jan 10, 2024 · a74e518 · a74e518
1 parent 8b3f03b
commit a74e518
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/...in/java/de/muenchen/oss/digiwf/connector/core/application/usecase/ExecuteTaskUseCase.java b/...in/java/de/muenchen/oss/digiwf/connector/core/application/usecase/ExecuteTaskUseCase.java
@@ -22,11 +22,9 @@ public void executeTask(@Valid ExecuteTaskCommand command) {
         log.info("Execute task with command {}", command);
 
         if (StringUtils.isNotBlank(command.getMessageName())) {
-            emitEventOutPort.emitEvent(command.getDestination(), command.getType(), command.getInstanceId(), command.getData());
-
-        } else {
             emitEventOutPort.emitEvent(command.getMessageName(), command.getDestination(), command.getType(), command.getInstanceId(), command.getData());
-
+        } else {
+            emitEventOutPort.emitEvent(command.getDestination(), command.getType(), command.getInstanceId(), command.getData());
         }
     }
 }
diff --git a/...ava/de/muenchen/oss/digiwf/connector/core/application/usecase/ExecuteTaskUseCaseTest.java b/...ava/de/muenchen/oss/digiwf/connector/core/application/usecase/ExecuteTaskUseCaseTest.java
@@ -36,7 +36,7 @@ void executeTask_shouldCallEmitEventWithCorrectParametersWhenMessageNameIsNotBla
         useCase.executeTask(command);
 
         // Assert
-        verify(emitEventOutPort).emitEvent(command.getDestination(), command.getType(), command.getInstanceId(), command.getData());
+        verify(emitEventOutPort).emitEvent(command.getMessageName(), command.getDestination(), command.getType(), command.getInstanceId(), command.getData());
     }
 
     @Test
@@ -53,6 +53,6 @@ void executeTask_shouldCallEmitEventWithDifferentParametersWhenMessageNameIsBlan
         useCase.executeTask(command);
 
         // Assert
-        verify(emitEventOutPort).emitEvent(command.getMessageName(), command.getDestination(), command.getType(), command.getInstanceId(), command.getData());
+        verify(emitEventOutPort).emitEvent(command.getDestination(), command.getType(), command.getInstanceId(), command.getData());
     }
 }