SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-1030 Add property for late initialization of AC

Browse Source 
Resolves #1030
This commit is contained in:
Oleg Zhurakousky
2023-05-24 11:28:34 +02:00
parent 53b61e5ebf
commit 1395424105
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/FunctionInvoker.java
View File

@@ -62,9 +62,17 @@ public class FunctionInvoker implements RequestStreamHandler {
private volatile String functionDefinition;
private boolean started;
public FunctionInvoker(String functionDefinition) {
this.functionDefinition = functionDefinition;
this.start();
String lateInitialization = System.getenv("FUNCTION_INVOKER_LATE_INITIALIZATION");
if (!StringUtils.hasText(lateInitialization) || !Boolean.parseBoolean(lateInitialization)) {
this.start();
}
else {
logger.info("Spring Application Context will be initialized on first request");
}
}
public FunctionInvoker() {
@@ -74,6 +82,9 @@ public class FunctionInvoker implements RequestStreamHandler {
@SuppressWarnings({ "rawtypes" })
@Override
public void handleRequest(InputStream input, OutputStream output, Context context) throws IOException {
if (!this.started) {
this.start();
}
Message requestMessage = AWSLambdaUtils
.generateMessage(input, this.function.getInputType(), this.function.isSupplier(), jsonMapper, context);
@@ -142,5 +153,6 @@ public class FunctionInvoker implements RequestStreamHandler {
if (logger.isInfoEnabled()) {
logger.info("Located function: '" + this.functionDefinition + "'");
}
this.started = true;
}
}