Skip to content

Commit 0bff089

Browse files
committed
fixed a bug where the annotation was not handled properly
1 parent 5290504 commit 0bff089

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

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

+9-1
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ private void applyFetchVariables(ZeebeWorkerValue zeebeWorkerValue) {
5454
}
5555
variables.addAll(
5656
readZeebeVariableParameters(zeebeWorkerValue.getMethodInfo()).stream()
57-
.map(ParameterInfo::getParameterName)
57+
.map(this::extractVariableName)
5858
.collect(Collectors.toList()));
5959
variables.addAll(readVariablesAsTypeParameters(zeebeWorkerValue.getMethodInfo()));
6060
zeebeWorkerValue.setFetchVariables(variables.toArray(new String[0]));
@@ -71,6 +71,14 @@ private List<ParameterInfo> readZeebeVariableParameters(MethodInfo methodInfo) {
7171
return result;
7272
}
7373

74+
private String extractVariableName(ParameterInfo parameterInfo) {
75+
Variable variableAnnotation = parameterInfo.getParameterInfo().getAnnotation(Variable.class);
76+
if (variableAnnotation != null && !Variable.DEFAULT_NAME.equals(variableAnnotation.name())) {
77+
return variableAnnotation.name();
78+
}
79+
return parameterInfo.getParameterName();
80+
}
81+
7482
private List<String> readVariablesAsTypeParameters(MethodInfo methodInfo) {
7583
List<String> result = new ArrayList<>();
7684
List<ParameterInfo> parameters =

0 commit comments

Comments
 (0)