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

SLEUTH-2051 Ensure that sleuth is not applied when reactive and non-message inputs are used

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-10-27 15:16:45 +02:00
parent b44984f59c
commit 62ffbc12b6
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionAroundWrapper.java
View File

@@ -40,7 +40,8 @@ public abstract class FunctionAroundWrapper implements BiFunction<Object, Functi
String functionalTracingEnabledStr = System.getProperty("spring.sleuth.function.enabled"); String functionalTracingEnabledStr = System.getProperty("spring.sleuth.function.enabled");
boolean functionalTracingEnabled = StringUtils.hasText(functionalTracingEnabledStr) boolean functionalTracingEnabled = StringUtils.hasText(functionalTracingEnabledStr)
? Boolean.parseBoolean(functionalTracingEnabledStr) : true; ? Boolean.parseBoolean(functionalTracingEnabledStr) : true;
if (functionalTracingEnabled) { if (functionalTracingEnabled && !targetFunction.isInputTypePublisher() &&
input instanceof Message && !FunctionTypeUtils.isCollectionOfMessage(targetFunction.getOutputType())) {
boolean isSkipOutputConversion = targetFunction.isSkipOutputConversion(); boolean isSkipOutputConversion = targetFunction.isSkipOutputConversion();
targetFunction.setSkipOutputConversion(true); targetFunction.setSkipOutputConversion(true);
try { try {