Dev/twegner/issue 18

samples/Exporters/TestApplicationInsights.cs

@@ -21,11 +21,13 @@ namespace Samples
     using System.Threading;
     using Microsoft.ApplicationInsights.Extensibility;
     using OpenTelemetry.Exporter.ApplicationInsights;
+    using OpenTelemetry.Internal;
     using OpenTelemetry.Stats;
     using OpenTelemetry.Stats.Aggregations;
     using OpenTelemetry.Stats.Measures;
     using OpenTelemetry.Tags;
     using OpenTelemetry.Trace;
+    using OpenTelemetry.Trace.Export;
     using OpenTelemetry.Trace.Sampler;
 
     internal class TestApplicationInsights
@@ -50,8 +52,11 @@ internal class TestApplicationInsights
 
         internal static object Run()
         {
+            SimpleEventQueue eventQueue = new SimpleEventQueue();
+            ExportComponent exportComponent = ExportComponent.CreateWithInProcessStores(eventQueue);
+
             TelemetryConfiguration.Active.InstrumentationKey = "instrumentation-key";
-            var exporter = new ApplicationInsightsExporter(Tracing.ExportComponent, Stats.ViewManager, TelemetryConfiguration.Active);
+            var exporter = new ApplicationInsightsExporter(exportComponent, Stats.ViewManager, TelemetryConfiguration.Active);
             exporter.Start();
 
             var tagContextBuilder = Tagger.CurrentBuilder.Put(FrontendKey, TagValue.Create("mobile-ios9.3.5"));
@@ -83,6 +88,8 @@ internal static object Run()
             Console.WriteLine("Done... wait for events to arrive to backend!");
             Console.ReadLine();
 
+            exportComponent.SpanExporter.Dispose();
+
             return null;
         }
     }

src/OpenTelemetry/Stats/CumulativeMutableViewData.cs

@@ -17,12 +17,13 @@
 namespace OpenTelemetry.Stats
 {
     using System;
+    using System.Collections.Concurrent;
     using System.Collections.Generic;
     using OpenTelemetry.Tags;
 
     internal class CumulativeMutableViewData : MutableViewData
     {
-        private readonly IDictionary<TagValues, MutableAggregation> tagValueAggregationMap = new Dictionary<TagValues, MutableAggregation>();
+        private readonly IDictionary<TagValues, MutableAggregation> tagValueAggregationMap = new ConcurrentDictionary<TagValues, MutableAggregation>();
         private DateTimeOffset start;
 
         internal CumulativeMutableViewData(IView view, DateTimeOffset start)

src/OpenTelemetry/Stats/MeasureMap.cs

@@ -18,6 +18,7 @@ namespace OpenTelemetry.Stats
 {
     using OpenTelemetry.Stats.Measures;
     using OpenTelemetry.Tags;
+    using OpenTelemetry.Tags.Unsafe;
 
     internal sealed class MeasureMap : MeasureMapBase
     {
@@ -44,7 +45,7 @@ public override IMeasureMap Put(IMeasureLong measure, long value)
         public override void Record()
         {
             // Use the context key directly, to avoid depending on the tags implementation.
-            this.Record(CurrentTagContextUtils.CurrentTagContext);
+            this.Record(AsyncLocalContext.CurrentTagContext);
         }
 
         public override void Record(ITagContext tags)