Skip to content

Commit 2f6f374

Browse files
committed
Rebase fix
1 parent b1b8f1e commit 2f6f374

File tree

3 files changed

+6
-5
lines changed

3 files changed

+6
-5
lines changed

tracer/src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Azure/Functions/AzureFunctionsCommon.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ _ when type.StartsWith("eventGrid", StringComparison.OrdinalIgnoreCase) => "Even
238238
{
239239
extractedContext = ExtractPropagatedContextFromHttp(context, entry.Key as string).MergeBaggageInto(Baggage.Current);
240240
}
241-
else if (triggerType == "ServiceBus" && tracer.Settings.IsIntegrationEnabled(IntegrationId.AzureServiceBus, false))
241+
else if (triggerType == "ServiceBus" && tracer.CurrentTraceSettings.Settings.IsIntegrationEnabled(IntegrationId.AzureServiceBus, false))
242242
{
243243
extractedContext = ExtractPropagatedContextFromServiceBus(context).MergeBaggageInto(Baggage.Current);
244244
}

tracer/src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Azure/ServiceBus/AzureServiceBusCommon.cs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -115,19 +115,20 @@ private static CallTargetState CreateSenderSpanInternal(
115115
IEnumerable<SpanLink>? spanLinks)
116116
{
117117
var tracer = Tracer.Instance;
118-
if (!tracer.Settings.IsIntegrationEnabled(IntegrationId.AzureServiceBus, false))
118+
var perTraceSettings = tracer.CurrentTraceSettings;
119+
if (!perTraceSettings.Settings.IsIntegrationEnabled(IntegrationId.AzureServiceBus, false))
119120
{
120121
return new CallTargetState(null);
121122
}
122123

123-
var tags = tracer.CurrentTraceSettings.Schema.Messaging.CreateAzureServiceBusTags(SpanKinds.Producer);
124+
var tags = perTraceSettings.Schema.Messaging.CreateAzureServiceBusTags(SpanKinds.Producer);
124125

125126
tags.MessagingDestinationName = entityPath;
126127
tags.MessagingOperation = operationName;
127128
tags.MessagingSystem = "servicebus";
128129
tags.InstrumentationName = "AzureServiceBus";
129130

130-
string serviceName = tracer.CurrentTraceSettings.Schema.Messaging.GetServiceName("azureservicebus");
131+
string serviceName = perTraceSettings.Schema.Messaging.GetServiceName("azureservicebus");
131132
var scope = tracer.StartActiveInternal(
132133
"azure_servicebus." + operationName,
133134
tags: tags,

tracer/src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Azure/ServiceBus/ServiceBusReceiverReceiveMessagesAsyncIntegration.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ internal static CallTargetState OnMethodBegin<TTarget>(TTarget instance, int max
4949
where TTarget : IServiceBusReceiver, IDuckType
5050
{
5151
var tracer = Tracer.Instance;
52-
if (!tracer.Settings.IsIntegrationEnabled(IntegrationId.AzureServiceBus, false))
52+
if (!tracer.CurrentTraceSettings.Settings.IsIntegrationEnabled(IntegrationId.AzureServiceBus, false))
5353
{
5454
return returnValue;
5555
}

0 commit comments

Comments
 (0)