added a test to assert on the bug fix

Author: jonathanlukas

spring-boot-starter-camunda/src/main/java/io/camunda/zeebe/spring/client/properties/PropertyBasedZeebeWorkerValueCustomizer.java

@@ -2,6 +2,7 @@
 
 import static org.apache.commons.lang3.StringUtils.*;
 
+import io.camunda.zeebe.client.api.response.ActivatedJob;
 import io.camunda.zeebe.spring.client.annotation.Variable;
 import io.camunda.zeebe.spring.client.annotation.VariablesAsType;
 import io.camunda.zeebe.spring.client.annotation.ZeebeVariable;
@@ -44,7 +45,11 @@ public void customize(ZeebeWorkerValue zeebeWorker) {
   }
 
   private void applyFetchVariables(ZeebeWorkerValue zeebeWorkerValue) {
-    if (zeebeWorkerValue.isForceFetchAllVariables()) {
+    if (hasActivatedJobInjected(zeebeWorkerValue)) {
+      LOG.debug(
+          "Worker '{}': ActivatedJob is injected, no variable filtering possible",
+          zeebeWorkerValue.getName());
+    } else if (zeebeWorkerValue.isForceFetchAllVariables()) {
       LOG.debug("Worker '{}': Force fetch all variables is enabled", zeebeWorkerValue.getName());
       zeebeWorkerValue.setFetchVariables(new String[0]);
     } else {
@@ -65,6 +70,11 @@ private void applyFetchVariables(ZeebeWorkerValue zeebeWorkerValue) {
     }
   }
 
+  private boolean hasActivatedJobInjected(ZeebeWorkerValue zeebeWorkerValue) {
+    return zeebeWorkerValue.getMethodInfo().getParameters().stream()
+        .anyMatch(p -> p.getParameterInfo().getType().isAssignableFrom(ActivatedJob.class));
+  }
+
   private List<ParameterInfo> readZeebeVariableParameters(MethodInfo methodInfo) {
     List<ParameterInfo> result = methodInfo.getParametersFilteredByAnnotation(Variable.class);
     result.addAll(methodInfo.getParametersFilteredByAnnotation(ZeebeVariable.class));

spring-boot-starter-camunda/src/test/java/io/camunda/zeebe/spring/client/properties/PropertyBasedZeebeWorkerValueCustomizerTest.java

@@ -2,6 +2,7 @@
 
 import static org.assertj.core.api.Assertions.*;
 
+import io.camunda.zeebe.client.api.response.ActivatedJob;
 import io.camunda.zeebe.spring.client.annotation.JobWorker;
 import io.camunda.zeebe.spring.client.annotation.Variable;
 import io.camunda.zeebe.spring.client.annotation.VariablesAsType;
@@ -38,6 +39,24 @@ private static ZeebeClientConfigurationProperties properties() {
   @JobWorker
   void sampleWorker(@Variable String var1, @VariablesAsType ComplexProcessVariable var2) {}
 
+  @JobWorker
+  void activatedJobWorker(@Variable String var1, ActivatedJob activatedJob) {}
+
+  @Test
+  void shouldNotAdjustVariableFilterVariablesAsActivatedJobIsInjected() {
+    // given
+    ZeebeClientConfigurationProperties properties = properties();
+    PropertyBasedZeebeWorkerValueCustomizer customizer =
+        new PropertyBasedZeebeWorkerValueCustomizer(properties);
+    ZeebeWorkerValue zeebeWorkerValue = new ZeebeWorkerValue();
+    zeebeWorkerValue.setFetchVariables(new String[] {"a", "var1", "b"});
+    zeebeWorkerValue.setMethodInfo(methodInfo(this, "testBean", "activatedJobWorker"));
+    // when
+    customizer.customize(zeebeWorkerValue);
+    // then
+    assertThat(zeebeWorkerValue.getFetchVariables()).containsExactly("a", "var1", "b");
+  }
+
   @Test
   void shouldSetDefaultName() throws NoSuchMethodException {
     // given