Skip to content

Commit 4b4d9ed

Browse files
committed
Follow the same queue class change as in open-telemetry/opentelemetry-java#7691
1 parent 862ac61 commit 4b4d9ed

File tree

1 file changed

+2
-2
lines changed
  • agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/telemetry

1 file changed

+2
-2
lines changed

agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/telemetry/BatchItemProcessor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
import com.azure.monitor.opentelemetry.autoconfigure.implementation.models.TelemetryItem;
1111
import com.azure.monitor.opentelemetry.autoconfigure.implementation.pipeline.TelemetryItemExporter;
1212
import io.opentelemetry.api.logs.LoggerProvider;
13-
import io.opentelemetry.internal.shaded.jctools.queues.MpscArrayQueue;
13+
import io.opentelemetry.internal.shaded.jctools.queues.atomic.MpscAtomicArrayQueue;
1414
import io.opentelemetry.javaagent.bootstrap.CallDepth;
1515
import io.opentelemetry.sdk.common.CompletableResultCode;
1616
import io.opentelemetry.sdk.internal.DaemonThreadFactory;
@@ -56,7 +56,7 @@ public static BatchItemProcessorBuilder builder(TelemetryItemExporter exporter)
5656
long exporterTimeoutNanos,
5757
int maxPendingExports,
5858
String queueName) {
59-
MpscArrayQueue<TelemetryItem> queue = new MpscArrayQueue<>(maxQueueSize);
59+
MpscAtomicArrayQueue<TelemetryItem> queue = new MpscAtomicArrayQueue<>(maxQueueSize);
6060
this.worker =
6161
new Worker(
6262
exporter,

0 commit comments

Comments
 (0)