respect activated job (#643)

Author: jonathanlukas

spring-client-zeebe/src/main/java/io/camunda/zeebe/spring/client/annotation/value/ZeebeWorkerValue.java

@@ -1,5 +1,6 @@
 package io.camunda.zeebe.spring.client.annotation.value;
 
+import io.camunda.zeebe.client.api.response.ActivatedJob;
 import io.camunda.zeebe.spring.client.annotation.Variable;
 import io.camunda.zeebe.spring.client.annotation.ZeebeVariable;
 import io.camunda.zeebe.spring.client.bean.CopyNotNullBeanUtilsBean;
@@ -267,7 +268,9 @@ public ZeebeWorkerValue initializeName(String name, MethodInfo methodInfo, Strin
   }
 
   public ZeebeWorkerValue initializeFetchVariables(boolean forceFetchAllVariables, String[] fetchVariables, MethodInfo methodInfo) {
-    if (forceFetchAllVariables) {
+    if (hasActivatedJobInjected()) {
+      // do nothing
+    } else if (forceFetchAllVariables) {
       // this overwrites any other setting
       setFetchVariables(new String[0]);
     } else {
@@ -280,6 +283,10 @@ public ZeebeWorkerValue initializeFetchVariables(boolean forceFetchAllVariables,
     return this;
   }
 
+  private boolean hasActivatedJobInjected() {
+    return 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));