Updating ActivityProcessor

src/OpenTelemetry/CHANGELOG.md

@@ -2,7 +2,11 @@
 
 ## Unreleased
 
-* `ActivityProcessor` implements IDisposable
+* `ActivityProcessor` implements IDisposable.
+  * When `Dispose` occurs, it calls `ShutdownAsync`.
+* `BatchingActivityProcessor`/`SimpleActivityProcessor` is disposable and it
+  disposes the containing exporter.
+* `BroadcastActivityProcessor`is disposable and it disposes the processors.
 
 ## 0.3.0-beta
 

test/OpenTelemetry.Instrumentation.SqlClient.Tests/SqlEventSourceTests.netfx.cs

@@ -131,8 +131,8 @@ public async Task SuccessfulCommandTest(CommandType commandType, string commandT
             int compositeState = successFlag | isSqlExceptionFlag | synchronousFlag;
 
             fakeSqlEventSource.WriteEndExecuteEvent(objectId, compositeState, sqlExceptionNumber);
-
-            Assert.InRange(activityProcessor.Invocations.Count, 2, 3);
+            shutdownSignal.Dispose();
+            Assert.Equal(3, activityProcessor.Invocations.Count);
 
             var activity = (Activity)activityProcessor.Invocations[1].Arguments[0];
 
@@ -153,7 +153,9 @@ public void EventSourceFakeUnknownEventWithNullPayloadTest()
 
             fakeSqlEventSource.WriteUnknownEventWithNullPayload();
 
-            Assert.InRange(activityProcessor.Invocations.Count, 0, 1);
+            shutdownSignal.Dispose();
+
+            Assert.Single(activityProcessor.Invocations);
         }
 
         [Fact]