Don't wrap collection of messages into Message
This commit is contained in:
@@ -711,7 +711,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
|
|||||||
if (functionInvocationHelper != null && CloudEventMessageUtils.isCloudEvent(((Message) input))) {
|
if (functionInvocationHelper != null && CloudEventMessageUtils.isCloudEvent(((Message) input))) {
|
||||||
result = functionInvocationHelper.postProcessResult(result, (Message) input);
|
result = functionInvocationHelper.postProcessResult(result, (Message) input);
|
||||||
}
|
}
|
||||||
else {
|
else if (!FunctionTypeUtils.isCollectionOfMessage(this.outputType)) {
|
||||||
result = MessageBuilder.withPayload(result).copyHeaders(this.sanitizeHeaders(((Message) input).getHeaders())).build();
|
result = MessageBuilder.withPayload(result).copyHeaders(this.sanitizeHeaders(((Message) input).getHeaders())).build();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -31,4 +31,14 @@ public class FunctionConfiguration {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
public Function<APIGatewayV2HTTPEvent, APIGatewayV2HTTPResponse> uppercaseApiGateway() {
|
||||||
|
return value -> {
|
||||||
|
APIGatewayV2HTTPResponse response = new APIGatewayV2HTTPResponse();
|
||||||
|
response.setStatusCode(404);
|
||||||
|
response.setBody("Resource not found");
|
||||||
|
return response;
|
||||||
|
};
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user