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

GH-399 Moved initialization of AWS context to constructor

Browse Source 
Moved initialization of AWS context to constructor for new FunctionInvoker

Resolves #399
This commit is contained in:
Oleg Zhurakousky
2019-12-16 20:25:09 +01:00
parent 7e0e8ff7ee
commit f094ea8595
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -64,15 +64,14 @@ public class FunctionInvoker implements RequestStreamHandler {
private ObjectMapper mapper; private ObjectMapper mapper;
private boolean started;
private Function<Message<byte[]>, Message<byte[]>> function; private Function<Message<byte[]>, Message<byte[]>> function;
public FunctionInvoker() {
this.start();
}
@Override @Override
public void handleRequest(InputStream input, OutputStream output, Context context) throws IOException { public void handleRequest(InputStream input, OutputStream output, Context context) throws IOException {
if (!this.started) {
this.start();
}
Message<byte[]> requestMessage = this.generateMessage(input, context); Message<byte[]> requestMessage = this.generateMessage(input, context);
@@ -115,7 +114,6 @@ public class FunctionInvoker implements RequestStreamHandler {
if (logger.isInfoEnabled()) { if (logger.isInfoEnabled()) {
logger.info("Located function: '" + functionName + "'"); logger.info("Located function: '" + functionName + "'");
} }
this.started = true;
} }
private void configureObjectMapper() { private void configureObjectMapper() {