Skip to content

Commit 066f3d1

Browse files
committed
GH-1145 Fix List conversion for Function<Message<List>, ..>
Resolves #1145
1 parent 48cc409 commit 066f3d1

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1343,6 +1343,12 @@ private Object convertInputMessageIfNecessary(Message message, Type type) {
13431343
if (collectionType == itemType) {
13441344
return message.getPayload();
13451345
}
1346+
1347+
if (collectionType != null
1348+
&& FunctionTypeUtils.getRawType(itemType).isAssignableFrom(collectionType.getClass())
1349+
&& FunctionTypeUtils.isMessage(type)) {
1350+
return message;
1351+
}
13461352
}
13471353

13481354
Object convertedInput = message.getPayload();

0 commit comments

Comments
 (0)