wip

gradle-plugin-8/src/main/java/org/camunda/community/bpmndt/GradlePlugin.java

@@ -62,8 +62,8 @@ public void apply(Project project) {
     }).get();
 
     // add generator task as test compile dependency
-    project.afterEvaluate(afterEvaluate -> {
-      afterEvaluate.getTasksByName(JavaPlugin.COMPILE_TEST_JAVA_TASK_NAME, false).forEach(task -> task.dependsOn(generatorTask));
-    });
+    project.afterEvaluate(afterEvaluate ->
+        afterEvaluate.getTasksByName(JavaPlugin.COMPILE_TEST_JAVA_TASK_NAME, false).forEach(task -> task.dependsOn(generatorTask))
+    );
   }
 }

gradle-plugin/src/main/java/org/camunda/community/bpmndt/GradlePlugin.java

@@ -63,8 +63,8 @@ public void apply(Project project) {
     }).get();
 
     // add generator task as test compile dependency
-    project.afterEvaluate(afterEvaluate -> {
-      afterEvaluate.getTasksByName(JavaPlugin.COMPILE_TEST_JAVA_TASK_NAME, false).forEach(task -> task.dependsOn(generatorTask));
-    });
+    project.afterEvaluate(afterEvaluate ->
+        afterEvaluate.getTasksByName(JavaPlugin.COMPILE_TEST_JAVA_TASK_NAME, false).forEach(task -> task.dependsOn(generatorTask))
+    );
   }
 }

impl/src/main/java/org/camunda/community/bpmndt/api/AbstractJUnit5TestCase.java

@@ -7,8 +7,7 @@
 /**
  * Abstract superclass for JUnit 5 based test cases.
  */
-public abstract class AbstractJUnit5TestCase<T extends AbstractTestCase<?>> extends AbstractTestCase<T>
-    implements BeforeEachCallback, AfterEachCallback {
+public abstract class AbstractJUnit5TestCase<T extends AbstractTestCase<?>> extends AbstractTestCase<T> implements BeforeEachCallback, AfterEachCallback {
 
   @Override
   public void beforeEach(ExtensionContext context) {

integration-tests-8/advanced-multi-instance.robot

@@ -25,7 +25,7 @@ mvn clean test
   Should contain  ${result.stdout}  Running org.example.it.UserTaskErrorTest
   Should contain  ${result.stdout}  Running org.example.it.UserTaskMessageTest
   # tests executed successfully
-  Should contain  ${result.stdout}  Failures: 0, Errors: 0, Skipped: 0
+  Should contain  ${result.stdout}  Failures: 0, Errors: 0, Skipped: 1
 
   Should be equal as integers  ${result.rc}  0
 
@@ -43,6 +43,6 @@ gradle clean build
   # tests executed
   Should contain  ${result.stdout}  finished executing tests
   # tests executed successfully
-  Should contain  ${result.stdout}  Failures: 0, Skipped: 0
+  Should contain  ${result.stdout}  Failures: 0, Skipped: 1
 
   Should be equal as integers  ${result.rc}  0

integration-tests-8/advanced.robot

@@ -22,6 +22,7 @@ mvn clean test
   Should contain  ${result.stdout}  Running org.example.it.CallActivityTimerTest
   Should contain  ${result.stdout}  Running org.example.it.CollaborationTest
   Should contain  ${result.stdout}  Running org.example.it.LinkEventTest
+  Should contain  ${result.stdout}  Running org.example.it.OutboundConnectorErrorTest
   Should contain  ${result.stdout}  Running org.example.it.ServiceTaskErrorTest
   Should contain  ${result.stdout}  Running org.example.it.ServiceTaskMessageTest
   Should contain  ${result.stdout}  Running org.example.it.ServiceTaskSignalTest
@@ -31,7 +32,7 @@ mvn clean test
   Should contain  ${result.stdout}  Running org.example.it.UserTaskSignalTest
   Should contain  ${result.stdout}  Running org.example.it.UserTaskTimerTest
   # tests executed successfully
-  Should contain  ${result.stdout}  Failures: 0, Errors: 0, Skipped: 0
+  Should contain  ${result.stdout}  Failures: 0, Errors: 0, Skipped: 1
 
   Should be equal as integers  ${result.rc}  0
 
@@ -49,6 +50,6 @@ gradle clean build
   # tests executed
   Should contain  ${result.stdout}  finished executing tests
   # tests executed successfully
-  Should contain  ${result.stdout}  Failures: 0, Skipped: 0
+  Should contain  ${result.stdout}  Failures: 0, Skipped: 1
 
   Should be equal as integers  ${result.rc}  0

integration-tests-8/advanced/src/test/java/org/example/it/OutboundConnectorErrorTest.java

@@ -0,0 +1,37 @@
+package org.example.it;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import generated.outboundconnectorerror.TC_startEvent__endEvent;
+import io.camunda.zeebe.process.test.api.ZeebeTestEngine;
+import io.camunda.zeebe.process.test.assertions.ProcessInstanceAssert;
+import io.camunda.zeebe.process.test.extension.ZeebeProcessTest;
+
+@ZeebeProcessTest
+public class OutboundConnectorErrorTest {
+
+  @RegisterExtension
+  TC_startEvent__endEvent tc = new TC_startEvent__endEvent();
+
+  ZeebeTestEngine engine;
+
+  @Test
+  void testExecute() {
+    tc.createExecutor(engine).verify(ProcessInstanceAssert::isCompleted).execute();
+  }
+
+  @Test
+  void testExecuteAction() {
+    tc.handleOutboundConnector().execute((client, jobKey) -> client.newThrowErrorCommand(jobKey).errorCode("ADVANCED_ERROR").send());
+
+    tc.createExecutor(engine).verify(ProcessInstanceAssert::isCompleted).execute();
+  }
+
+  @Test
+  void testThrowBpmnError() {
+    tc.handleOutboundConnector().throwBpmnError("ADVANCED_ERROR", "test error message");
+
+    tc.createExecutor(engine).verify(ProcessInstanceAssert::isCompleted).execute();
+  }
+}