Skip to content

Commit 05416db

Browse files
committed
GH-STREAM 2704 Fix Consumer CCE on Kotlin Consumer
Resolves #2704
1 parent 091d4ed commit 05416db

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,11 @@ public Object invoke(Object arg0) {
123123
if (this.kotlinLambdaTarget instanceof Function1) {
124124
return ((Function1) this.kotlinLambdaTarget).invoke(arg0);
125125
}
126-
return ((Function) this.kotlinLambdaTarget).apply(arg0);
126+
else if (this.kotlinLambdaTarget instanceof Function) {
127+
return ((Function) this.kotlinLambdaTarget).apply(arg0);
128+
}
129+
((Consumer) this.kotlinLambdaTarget).accept(arg0);
130+
return null;
127131
}
128132

129133
@Override

0 commit comments

Comments
 (0)