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

GH-1198 Fix tracibility wrapper

Browse Source 
Fix tracibility wrapper to ensure traceid/spanid are captured on subsequent invocations

Resolves #1198
This commit is contained in:
Oleg Zhurakousky
2024-10-29 14:50:47 +01:00
parent 3968e370dd
commit 2b3318de53
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -16,8 +16,6 @@
package org.springframework.cloud.function.context.catalog;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.reactivestreams.Publisher;
import org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry.FunctionInvocationWrapper;
@@ -37,14 +35,15 @@ import org.springframework.util.StringUtils;
*/
public abstract class FunctionAroundWrapper {
private static final Log log = LogFactory.getLog(FunctionAroundWrapper.class);
public final Object apply(Object input, FunctionInvocationWrapper targetFunction) {
String functionalTracingEnabledStr = System.getProperty("spring.cloud.function.observability.enabled");
boolean functionalTracingEnabled = !StringUtils.hasText(functionalTracingEnabledStr)
|| Boolean.parseBoolean(functionalTracingEnabledStr);
if (functionalTracingEnabled && !(input instanceof Publisher) && input instanceof Message && !FunctionTypeUtils.isCollectionOfMessage(targetFunction.getOutputType())) {
return this.doApply(input, targetFunction);
Object result = this.doApply(input, targetFunction);
targetFunction.wrapped = false;
return result;
}
else {
return targetFunction.apply(input);

2
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
View File

@@ -417,7 +417,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry {
private boolean propagateInputHeaders;
private boolean wrapped;
protected boolean wrapped;
private final ThreadLocal<Message<Object>> unconvertedResult = new ThreadLocal<>();