Skip to content

Commit 217d595

Browse files
committed
moved to zeebe 8.3.7
1 parent d6340ea commit 217d595

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

pom.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
<maven.compiler.source>${java.version}</maven.compiler.source>
2020
<maven.compiler.target>${java.version}</maven.compiler.target>
2121

22-
<zeebe.version>8.3.5</zeebe.version>
22+
<zeebe.version>8.3.7</zeebe.version>
2323

2424
<spring-boot.version>3.2.0</spring-boot.version>
2525
<commons-beanutils.version>1.9.4</commons-beanutils.version>

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

+11-1
Original file line numberDiff line numberDiff line change
@@ -274,7 +274,7 @@ public ZeebeWorkerValue initializeFetchVariables(boolean forceFetchAllVariables,
274274
// make sure variables configured and annotated parameters are both fetched, use a set to avoid duplicates
275275
Set<String> variables = new HashSet<>();
276276
variables.addAll(Arrays.asList(fetchVariables));
277-
variables.addAll(readZeebeVariableParameters(methodInfo).stream().map(ParameterInfo::getParameterName).collect(Collectors.toList()));
277+
variables.addAll(readZeebeVariableParameters(methodInfo).stream().map(this::variableNameFromParameter).collect(Collectors.toList()));
278278
setFetchVariables(variables.toArray(new String[0]));
279279
}
280280
return this;
@@ -286,6 +286,16 @@ private List<ParameterInfo> readZeebeVariableParameters(MethodInfo methodInfo) {
286286
return result;
287287
}
288288

289+
private String variableNameFromParameter(ParameterInfo parameterInfo){
290+
Variable variableAnnotation = parameterInfo
291+
.getParameterInfo()
292+
.getAnnotation(Variable.class);
293+
if(!variableAnnotation.name().equals(Variable.DEFAULT_NAME)){
294+
return variableAnnotation.name();
295+
}
296+
return parameterInfo.getParameterName();
297+
}
298+
289299
public ZeebeWorkerValue initializeJobType(String jobType, MethodInfo methodInfo, String defaultWorkerType) {
290300
if (jobType!=null && jobType.length() > 0) {
291301
setType(jobType);

0 commit comments

Comments
 (0)