updates

newrelic-experimental · Jun 12, 2024 · 5f92043 · 5f92043
1 parent 60fb9af
commit 5f92043
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...src/main/java/com/nr/instrumentation/apache/camel/AggregateProcessor_instrumentation.java b/...src/main/java/com/nr/instrumentation/apache/camel/AggregateProcessor_instrumentation.java
@@ -9,6 +9,7 @@
 import com.newrelic.api.agent.NewRelic;
 import com.newrelic.api.agent.Trace;
 import com.newrelic.api.agent.TransactionNamePriority;
+import com.newrelic.api.agent.TransportType;
 import com.newrelic.api.agent.weaver.Weave;
 import com.newrelic.api.agent.weaver.Weaver;
 
@@ -25,6 +26,7 @@ protected boolean doProcess(Exchange exchange, AsyncCallback callback) {
 			NewRelic.getAgent().getTracedMethod().setMetricName(new String[] {"Custom","AggregateProcessor","doProcess",routeID});
 			NewRelic.getAgent().getTransaction().setTransactionName(TransactionNamePriority.FRAMEWORK_LOW, false, "CamelProcessor", new String[] {"AggregateProcessor",routeID});
 		}
+		NewRelic.getAgent().getTransaction().acceptDistributedTraceHeaders(TransportType.Other, new CamelHeaders(exchange));
 		return Weaver.callOriginal();
 	}
 
@@ -36,6 +38,7 @@ protected boolean doProcess(Exchange exchange, String key, AsyncCallback callbac
 			NewRelic.getAgent().getTracedMethod().setMetricName(new String[] {"Custom","AggregateProcessor","doProcess",routeID});
 			NewRelic.getAgent().getTransaction().setTransactionName(TransactionNamePriority.FRAMEWORK_LOW, false, "CamelProcessor", new String[] {"AggregateProcessor",routeID});
 		}
+		NewRelic.getAgent().getTransaction().acceptDistributedTraceHeaders(TransportType.Other, new CamelHeaders(exchange));
 
 		return Weaver.callOriginal();
 	}

diff --git a/settings.gradle b/settings.gradle
@@ -11,7 +11,7 @@ include 'camel-core-3.9'
 include 'camel-core-3.18'
 include 'camel-jms-3.18'
 include 'camel-core-4.0.0'
-include 'camel-core-4.1'
+include 'camel-core-4.1.0'
 include 'camel-jms-4.0.0'
 include 'camel-netty-3.0'
 include 'camel-netty-3.18'