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

Add additional logging to CustomRuntimeEventLoop

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-12-06 12:55:42 +01:00
parent 0475ae5671
commit 5f7313ff31
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -174,25 +174,33 @@ public final class CustomRuntimeEventLoop implements SmartLifecycle {
private FunctionInvocationWrapper locateFunction(Environment environment, FunctionCatalog functionCatalog, MediaType contentType) { private FunctionInvocationWrapper locateFunction(Environment environment, FunctionCatalog functionCatalog, MediaType contentType) {
String handlerName = environment.getProperty("DEFAULT_HANDLER"); String handlerName = environment.getProperty("DEFAULT_HANDLER");
if (logger.isDebugEnabled()) {
logger.debug("Value of DEFAULT_HANDLER env: " + handlerName);
}
FunctionInvocationWrapper function = functionCatalog.lookup(handlerName, contentType.toString()); FunctionInvocationWrapper function = functionCatalog.lookup(handlerName, contentType.toString());
if (function == null) { if (function == null) {
logger.debug("Could not locate function under DEFAULT_HANDLER");
handlerName = environment.getProperty("_HANDLER"); handlerName = environment.getProperty("_HANDLER");
if (logger.isDebugEnabled()) {
logger.debug("Value of _HANDLER env: " + handlerName);
}
function = functionCatalog.lookup(handlerName, contentType.toString()); function = functionCatalog.lookup(handlerName, contentType.toString());
} }
if (function == null) { if (function == null) {
function = functionCatalog.lookup(null, contentType.toString()); logger.debug("Could not locate function under _HANDLER");
function = functionCatalog.lookup((String) null, contentType.toString());
} }
if (function == null) { if (function == null) {
logger.info("Could not determine default function");
handlerName = environment.getProperty("spring.cloud.function.definition"); handlerName = environment.getProperty("spring.cloud.function.definition");
if (logger.isDebugEnabled()) {
logger.debug("Value of 'spring.cloud.function.definition' env: " + handlerName);
}
function = functionCatalog.lookup(handlerName, contentType.toString()); function = functionCatalog.lookup(handlerName, contentType.toString());
} }
if (function == null) {
function = functionCatalog.lookup(null, contentType.toString());
}
Assert.notNull(function, "Failed to locate function. Tried locating default function, " Assert.notNull(function, "Failed to locate function. Tried locating default function, "
+ "function by 'DEFAULT_HANDLER', '_HANDLER' env variable as well as'spring.cloud.function.definition'. " + "function by 'DEFAULT_HANDLER', '_HANDLER' env variable as well as'spring.cloud.function.definition'. "
+ "Functions available in catalog are: " + functionCatalog.getNames(null)); + "Functions available in catalog are: " + functionCatalog.getNames(null));