[Event Hubs] Add missing metadata to PartitionContext (#26737)

jsquire · web-flow · commit d970ca1ea3ae · 2022-02-04T16:47:00.000-05:00
The focus of these changes is to add metadata about the associated Event Hub
instance to the `PartitionContext` used by the consumer and processor clients.
These fields are present in Java, Python, and JavaScript but are missing in
.NET for some reason.
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs.Processor/Azure.Messaging.EventHubs.Processor.slnf b/sdk/eventhub/Azure.Messaging.EventHubs.Processor/Azure.Messaging.EventHubs.Processor.slnf
@@ -6,4 +6,4 @@
       "Azure.Messaging.EventHubs.Processor\\tests\\Azure.Messaging.EventHubs.Processor.Tests.csproj"
     ]
   }
-}
+}
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs.Processor/CHANGELOG.md b/sdk/eventhub/Azure.Messaging.EventHubs.Processor/CHANGELOG.md
@@ -4,11 +4,7 @@
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+- Added `FullyQualifiedNamespace`, `EventHubName`, and `ConsumerGroup` to the partition context associated with events dispatched for processing.
 
 ## 5.7.0-beta.2 (2022-01-13)
 
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs.Processor/src/Azure.Messaging.EventHubs.Processor.csproj b/sdk/eventhub/Azure.Messaging.EventHubs.Processor/src/Azure.Messaging.EventHubs.Processor.csproj
@@ -21,7 +21,14 @@
     <PackageReference Include="Azure.Core.Experimental" />
     <!-- END TEMP -->
 
-    <PackageReference Include="Azure.Messaging.EventHubs" VersionOverride="5.7.0-beta.2" /><!-- TEMP:  Remove after the 5.7.0 line goes GA -->
+    <!--
+        TEMP: Restore to package reference after the next release.
+
+    <PackageReference Include="Azure.Messaging.EventHubs" VersionOverride="5.7.0-beta.2" />
+    -->
+    <ProjectReference Include="$(MSBuildThisFileDirectory)..\..\Azure.Messaging.EventHubs\src\Azure.Messaging.EventHubs.csproj" />
+    <!-- END TEMP -->
+
     <PackageReference Include="Azure.Storage.Blobs" />
     <PackageReference Include="Microsoft.Azure.Amqp" />
     <PackageReference Include="Microsoft.Bcl.AsyncInterfaces" />
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs.Processor/src/EventProcessorClient.cs b/sdk/eventhub/Azure.Messaging.EventHubs.Processor/src/EventProcessorClient.cs
@@ -923,7 +923,7 @@ protected override async Task OnProcessingEventBatchAsync(IEnumerable<EventData>
 
                     try
                     {
-                        context ??= new ProcessorPartitionContext(partition.PartitionId, () => ReadLastEnqueuedEventProperties(partition.PartitionId));
+                        context ??= new ProcessorPartitionContext(FullyQualifiedNamespace, EventHubName, ConsumerGroup, partition.PartitionId, () => ReadLastEnqueuedEventProperties(partition.PartitionId));
                         eventArgs = new ProcessEventArgs(context, eventData, updateToken => UpdateCheckpointAsync(eventData, context, updateToken), cancellationToken);
 
                         await _processEventAsync(eventArgs).ConfigureAwait(false);
@@ -945,7 +945,7 @@ protected override async Task OnProcessingEventBatchAsync(IEnumerable<EventData>
 
                 if (emptyBatch)
                 {
-                    eventArgs = new ProcessEventArgs(new EmptyPartitionContext(partition.PartitionId), null, EmptyEventUpdateCheckpoint, cancellationToken);
+                    eventArgs = new ProcessEventArgs(new EmptyPartitionContext(FullyQualifiedNamespace, EventHubName, ConsumerGroup, partition.PartitionId), null, EmptyEventUpdateCheckpoint, cancellationToken);
                     await _processEventAsync(eventArgs).ConfigureAwait(false);
                 }
             }
@@ -1367,11 +1367,17 @@ private class ProcessorPartitionContext : PartitionContext
             ///   Initializes a new instance of the <see cref="EmptyPartitionContext" /> class.
             /// </summary>
             ///
-            /// <param name="partitionId">The identifier of the partition that the context represents.</param>
+            /// <param name="fullyQualifiedNamespace">The fully qualified Event Hubs namespace this context is associated with.</param>
+            /// <param name="eventHubName">The name of the Event Hub partition this context is associated with.</param>
+            /// <param name="consumerGroup">The name of the consumer group this context is associated with.</param>
+            /// <param name="partitionId">The identifier of the Event Hub partition this context is associated with.</param>
             /// <param name="readLastEnqueuedEventProperties">A function that can be used to read the last enqueued event properties for the partition.</param>
             ///
-            public ProcessorPartitionContext(string partitionId,
-                                             Func<LastEnqueuedEventProperties> readLastEnqueuedEventProperties) : base(partitionId)
+            public ProcessorPartitionContext(string fullyQualifiedNamespace,
+                                             string eventHubName,
+                                             string consumerGroup,
+                                             string partitionId,
+                                             Func<LastEnqueuedEventProperties> readLastEnqueuedEventProperties) : base(fullyQualifiedNamespace, eventHubName, consumerGroup, partitionId)
             {
                 _readLastEnqueuedEventProperties = readLastEnqueuedEventProperties;
             }
@@ -1399,9 +1405,15 @@ private class EmptyPartitionContext : PartitionContext
             ///   Initializes a new instance of the <see cref="EmptyPartitionContext" /> class.
             /// </summary>
             ///
-            /// <param name="partitionId">The identifier of the partition that the context represents.</param>
+            /// <param name="fullyQualifiedNamespace">The fully qualified Event Hubs namespace this context is associated with.</param>
+            /// <param name="eventHubName">The name of the Event Hub partition this context is associated with.</param>
+            /// <param name="consumerGroup">The name of the consumer group this context is associated with.</param>
+            /// <param name="partitionId">The identifier of the Event Hub partition this context is associated with.</param>
             ///
-            public EmptyPartitionContext(string partitionId) : base(partitionId)
+            public EmptyPartitionContext(string fullyQualifiedNamespace,
+                                         string eventHubName,
+                                         string consumerGroup,
+                                         string partitionId) : base(fullyQualifiedNamespace, eventHubName, consumerGroup, partitionId)
             {
             }
 
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs.Processor/tests/Processor/EventProcessorClientTests.cs b/sdk/eventhub/Azure.Messaging.EventHubs.Processor/tests/Processor/EventProcessorClientTests.cs
@@ -939,6 +939,9 @@ public async Task ProcessorRaisesProcessEventHandlerWhenEventsAreRead()
             for (var index = 0; index < eventBatch.Length; ++index)
             {
                 Assert.That(capturedEventArgs[index].HasEvent, Is.True, $"The event arguments should contain an event at index { index }.");
+                Assert.That(capturedEventArgs[index].Partition.FullyQualifiedNamespace, Is.EqualTo(processorClient.FullyQualifiedNamespace), "The fully qualified namespace should have been propagated.");
+                Assert.That(capturedEventArgs[index].Partition.EventHubName, Is.EqualTo(processorClient.EventHubName), "The event hub name should have been propagated.");
+                Assert.That(capturedEventArgs[index].Partition.ConsumerGroup, Is.EqualTo(processorClient.ConsumerGroup), "The consumer group should have been propagated.");
                 Assert.That(capturedEventArgs[index].Partition.PartitionId, Is.EqualTo(partitionId), $"The partition identifier should have been propagated at index { index }.");
                 Assert.That(capturedEventArgs[index].Data.IsEquivalentTo(eventBatch[index]), Is.True, $"The event should have been propagated and order preserved at index { index }.");
                 Assert.That(capturedEventArgs[index].CancellationToken, Is.EqualTo(cancellationSource.Token), $"The cancellation token should have been propagated at index { index }.");
@@ -984,6 +987,9 @@ public async Task ProcessorRaisesProcessEventHandlerWithAnEmptyContextWhenThereA
 
             Assert.That(capturedEventArgs, Is.Not.Null, "The event handler should have been fired.");
             Assert.That(capturedEventArgs.HasEvent, Is.False, "The event arguments should not contain an event.");
+            Assert.That(capturedEventArgs.Partition.FullyQualifiedNamespace, Is.EqualTo(processorClient.FullyQualifiedNamespace), "The fully qualified namespace should have been propagated.");
+            Assert.That(capturedEventArgs.Partition.EventHubName, Is.EqualTo(processorClient.EventHubName), "The event hub name should have been propagated.");
+            Assert.That(capturedEventArgs.Partition.ConsumerGroup, Is.EqualTo(processorClient.ConsumerGroup), "The consumer group should have been propagated.");
             Assert.That(capturedEventArgs.Partition.PartitionId, Is.EqualTo(partitionId), "The partition identifier should have been propagated.");
             Assert.That(capturedEventArgs.Data, Is.Null, "No event data should have been propagated.");
             Assert.That(capturedEventArgs.CancellationToken, Is.EqualTo(cancellationSource.Token), "The cancellation token should have been propagated.");
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/CHANGELOG.md b/sdk/eventhub/Azure.Messaging.EventHubs/CHANGELOG.md
@@ -4,11 +4,7 @@
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+- Added `FullyQualifiedNamespace`, `EventHubName`, and `ConsumerGroup` to the partition context associated with events read by the `EventHubConsumerClient`.
 
 ## 5.7.0-beta.2 (2022-01-13)
 
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/api/Azure.Messaging.EventHubs.netstandard2.0.cs b/sdk/eventhub/Azure.Messaging.EventHubs/api/Azure.Messaging.EventHubs.netstandard2.0.cs
@@ -140,7 +140,9 @@ public static partial class EventHubsModelFactory
         public static Azure.Messaging.EventHubs.Producer.EventDataBatch EventDataBatch(long batchSizeBytes, System.Collections.Generic.IList<Azure.Messaging.EventHubs.EventData> batchEventStore, Azure.Messaging.EventHubs.Producer.CreateBatchOptions batchOptions = null, System.Func<Azure.Messaging.EventHubs.EventData, bool> tryAddCallback = null) { throw null; }
         public static Azure.Messaging.EventHubs.EventHubProperties EventHubProperties(string name, System.DateTimeOffset createdOn, string[] partitionIds) { throw null; }
         public static Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties LastEnqueuedEventProperties(long? lastSequenceNumber, long? lastOffset, System.DateTimeOffset? lastEnqueuedTime, System.DateTimeOffset? lastReceivedTime) { throw null; }
+        [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)]
         public static Azure.Messaging.EventHubs.Consumer.PartitionContext PartitionContext(string partitionId, Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties lastEnqueuedEventProperties = default(Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties)) { throw null; }
+        public static Azure.Messaging.EventHubs.Consumer.PartitionContext PartitionContext(string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties lastEnqueuedEventProperties = default(Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties)) { throw null; }
         public static Azure.Messaging.EventHubs.PartitionProperties PartitionProperties(string eventHubName, string partitionId, bool isEmpty, long beginningSequenceNumber, long lastSequenceNumber, long lastOffset, System.DateTimeOffset lastEnqueuedTime) { throw null; }
     }
     public enum EventHubsRetryMode
@@ -281,7 +283,12 @@ public partial struct LastEnqueuedEventProperties : System.IEquatable<Azure.Mess
     }
     public partial class PartitionContext
     {
-        protected internal PartitionContext(string partitionId) { }
+        [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)]
+        protected PartitionContext(string partitionId) { }
+        protected internal PartitionContext(string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId) { }
+        public string ConsumerGroup { get { throw null; } }
+        public string EventHubName { get { throw null; } }
+        public string FullyQualifiedNamespace { get { throw null; } }
         public string PartitionId { get { throw null; } }
         public virtual Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties ReadLastEnqueuedEventProperties() { throw null; }
     }
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/src/Consumer/EventHubConsumerClient.cs b/sdk/eventhub/Azure.Messaging.EventHubs/src/Consumer/EventHubConsumerClient.cs
@@ -487,7 +487,7 @@ public virtual async IAsyncEnumerable<PartitionEvent> ReadEventsFromPartitionAsy
                 try
                 {
                     transportConsumer = Connection.CreateTransportConsumer(ConsumerGroup, partitionId, Identifier, startingPosition, RetryPolicy, readOptions.TrackLastEnqueuedEventProperties, InvalidateConsumerWhenPartitionIsStolen, readOptions.OwnerLevel, (uint)readOptions.PrefetchCount);
-                    partitionContext = new PartitionContext(partitionId, transportConsumer);
+                    partitionContext = new PartitionContext(FullyQualifiedNamespace, EventHubName, ConsumerGroup, partitionId, transportConsumer);
                     emptyPartitionEvent = new PartitionEvent(partitionContext, null);
                 }
                 catch (Exception ex)
@@ -987,7 +987,7 @@ void exceptionCallback(Exception ex)
                 (
                     transportConsumer,
                     channel,
-                    new PartitionContext(partitionId, transportConsumer),
+                    new PartitionContext(FullyQualifiedNamespace, EventHubName, ConsumerGroup, partitionId, transportConsumer),
                     receiveBatchSize,
                     exceptionCallback,
                     publishingCancellationSource.Token
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/src/Consumer/PartitionContext.cs b/sdk/eventhub/Azure.Messaging.EventHubs/src/Consumer/PartitionContext.cs
@@ -2,6 +2,7 @@
 // Licensed under the MIT License.
 
 using System;
+using System.ComponentModel;
 using Azure.Core;
 using Azure.Messaging.EventHubs.Core;
 
@@ -14,6 +15,24 @@ namespace Azure.Messaging.EventHubs.Consumer
     ///
     public class PartitionContext
     {
+        /// <summary>
+        ///   The fully qualified Event Hubs namespace that this context is associated with.
+        /// </summary>
+        ///
+        public string FullyQualifiedNamespace { get; }
+
+        /// <summary>
+        ///   The name of the Event Hub that this context is associated with.
+        /// </summary>
+        ///
+        public string EventHubName { get; }
+
+        /// <summary>
+        ///   The name of the consumer group that this context is associated with.
+        /// </summary>
+        ///
+        public string ConsumerGroup { get; }
+
         /// <summary>
         ///   The identifier of the Event Hub partition this context is associated with.
         /// </summary>
@@ -62,6 +81,9 @@ public virtual LastEnqueuedEventProperties ReadLastEnqueuedEventProperties()
         ///   Initializes a new instance of the <see cref="PartitionContext"/> class.
         /// </summary>
         ///
+        /// <param name="fullyQualifiedNamespace">The fully qualified Event Hubs namespace this context is associated with.</param>
+        /// <param name="eventHubName">The name of the Event Hub partition this context is associated with.</param>
+        /// <param name="consumerGroup">The name of the consumer group this context is associated with.</param>
         /// <param name="partitionId">The identifier of the Event Hub partition this context is associated with.</param>
         /// <param name="consumer">The <see cref="TransportConsumer" /> for this context to use as the source for information.</param>
         ///
@@ -71,8 +93,11 @@ public virtual LastEnqueuedEventProperties ReadLastEnqueuedEventProperties()
         ///   consumer instance.
         /// </remarks>
         ///
-        internal PartitionContext(string partitionId,
-                                  TransportConsumer consumer) : this(partitionId)
+        internal PartitionContext(string fullyQualifiedNamespace,
+                                  string eventHubName,
+                                  string consumerGroup,
+                                  string partitionId,
+                                  TransportConsumer consumer) : this(fullyQualifiedNamespace, eventHubName, consumerGroup, partitionId)
         {
             Argument.AssertNotNull(consumer, nameof(consumer));
             SourceConsumer = new WeakReference<TransportConsumer>(consumer);
@@ -82,9 +107,40 @@ internal PartitionContext(string partitionId,
         ///   Initializes a new instance of the <see cref="PartitionContext"/> class.
         /// </summary>
         ///
+        /// <param name="fullyQualifiedNamespace">The fully qualified Event Hubs namespace this context is associated with.</param>
+        /// <param name="eventHubName">The name of the Event Hub partition this context is associated with.</param>
+        /// <param name="consumerGroup">The name of the consumer group this context is associated with.</param>
         /// <param name="partitionId">The identifier of the Event Hub partition this context is associated with.</param>
         ///
-        protected internal PartitionContext(string partitionId)
+        protected internal PartitionContext(string fullyQualifiedNamespace,
+                                            string eventHubName,
+                                            string consumerGroup,
+                                            string partitionId)
+        {
+            Argument.AssertNotNullOrEmpty(fullyQualifiedNamespace, nameof(fullyQualifiedNamespace));
+            Argument.AssertNotNullOrEmpty(eventHubName, nameof(eventHubName));
+            Argument.AssertNotNullOrEmpty(consumerGroup, nameof(consumerGroup));
+            Argument.AssertNotNullOrEmpty(partitionId, nameof(partitionId));
+
+            FullyQualifiedNamespace = fullyQualifiedNamespace;
+            EventHubName = eventHubName;
+            ConsumerGroup = consumerGroup;
+            PartitionId = partitionId;
+        }
+
+        /// <summary>
+        ///   Initializes a new instance of the <see cref="PartitionContext"/> class.
+        /// </summary>
+        ///
+        /// <param name="partitionId">The identifier of the Event Hub partition this context is associated with.</param>
+        ///
+        /// <remarks>
+        ///   This overload should no longer be used; it does not set the members of
+        ///   the context not specified.
+        /// </remarks>
+        ///
+        [EditorBrowsable(EditorBrowsableState.Never)]
+        protected PartitionContext(string partitionId)
         {
             Argument.AssertNotNullOrEmpty(partitionId, nameof(partitionId));
             PartitionId = partitionId;
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/src/EventHubsModelFactory.cs b/sdk/eventhub/Azure.Messaging.EventHubs/src/EventHubsModelFactory.cs
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/tests/Consumer/EventHubConsumerClientTests.cs b/sdk/eventhub/Azure.Messaging.EventHubs/tests/Consumer/EventHubConsumerClientTests.cs
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/tests/Consumer/PartitionContextTests.cs b/sdk/eventhub/Azure.Messaging.EventHubs/tests/Consumer/PartitionContextTests.cs
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/tests/Core/EventHubsModelFactoryTests.cs b/sdk/eventhub/Azure.Messaging.EventHubs/tests/Core/EventHubsModelFactoryTests.cs

Original file line number	Diff line number	Diff line change
`@@ -6,4 +6,4 @@`
`6`	`6`	`"Azure.Messaging.EventHubs.Processor\\tests\\Azure.Messaging.EventHubs.Processor.Tests.csproj"`
`7`	`7`	`]`
`8`	`8`	`}`
`9`		`-}`
	`9`	`+}`
Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,9 @@ public static partial class EventHubsModelFactory`
`140`	`140`	`public static Azure.Messaging.EventHubs.Producer.EventDataBatch EventDataBatch(long batchSizeBytes, System.Collections.Generic.IList<Azure.Messaging.EventHubs.EventData> batchEventStore, Azure.Messaging.EventHubs.Producer.CreateBatchOptions batchOptions = null, System.Func<Azure.Messaging.EventHubs.EventData, bool> tryAddCallback = null) { throw null; }`
`141`	`141`	`public static Azure.Messaging.EventHubs.EventHubProperties EventHubProperties(string name, System.DateTimeOffset createdOn, string[] partitionIds) { throw null; }`
`142`	`142`	`public static Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties LastEnqueuedEventProperties(long? lastSequenceNumber, long? lastOffset, System.DateTimeOffset? lastEnqueuedTime, System.DateTimeOffset? lastReceivedTime) { throw null; }`
	`143`	`+ [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)]`
`143`	`144`	`public static Azure.Messaging.EventHubs.Consumer.PartitionContext PartitionContext(string partitionId, Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties lastEnqueuedEventProperties = default(Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties)) { throw null; }`
	`145`	`+ public static Azure.Messaging.EventHubs.Consumer.PartitionContext PartitionContext(string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties lastEnqueuedEventProperties = default(Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties)) { throw null; }`
`144`	`146`	`public static Azure.Messaging.EventHubs.PartitionProperties PartitionProperties(string eventHubName, string partitionId, bool isEmpty, long beginningSequenceNumber, long lastSequenceNumber, long lastOffset, System.DateTimeOffset lastEnqueuedTime) { throw null; }`
`145`	`147`	`}`
`146`	`148`	`public enum EventHubsRetryMode`
`@@ -281,7 +283,12 @@ public partial struct LastEnqueuedEventProperties : System.IEquatable<Azure.Mess`
`281`	`283`	`}`
`282`	`284`	`public partial class PartitionContext`
`283`	`285`	`{`
`284`		`- protected internal PartitionContext(string partitionId) { }`
	`286`	`+ [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)]`
	`287`	`+ protected PartitionContext(string partitionId) { }`
	`288`	`+ protected internal PartitionContext(string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId) { }`
	`289`	`+ public string ConsumerGroup { get { throw null; } }`
	`290`	`+ public string EventHubName { get { throw null; } }`
	`291`	`+ public string FullyQualifiedNamespace { get { throw null; } }`
`285`	`292`	`public string PartitionId { get { throw null; } }`
`286`	`293`	`public virtual Azure.Messaging.EventHubs.Consumer.LastEnqueuedEventProperties ReadLastEnqueuedEventProperties() { throw null; }`
`287`	`294`	`}`
Original file line number	Diff line number	Diff line change
`@@ -487,7 +487,7 @@ public virtual async IAsyncEnumerable<PartitionEvent> ReadEventsFromPartitionAsy`
`487`	`487`	`try`
`488`	`488`	`{`
`489`	`489`	`transportConsumer = Connection.CreateTransportConsumer(ConsumerGroup, partitionId, Identifier, startingPosition, RetryPolicy, readOptions.TrackLastEnqueuedEventProperties, InvalidateConsumerWhenPartitionIsStolen, readOptions.OwnerLevel, (uint)readOptions.PrefetchCount);`
`490`		`- partitionContext = new PartitionContext(partitionId, transportConsumer);`
	`490`	`+ partitionContext = new PartitionContext(FullyQualifiedNamespace, EventHubName, ConsumerGroup, partitionId, transportConsumer);`
`491`	`491`	`emptyPartitionEvent = new PartitionEvent(partitionContext, null);`
`492`	`492`	`}`
`493`	`493`	`catch (Exception ex)`
`@@ -987,7 +987,7 @@ void exceptionCallback(Exception ex)`
`987`	`987`	`(`
`988`	`988`	`transportConsumer,`
`989`	`989`	`channel,`
`990`		`- new PartitionContext(partitionId, transportConsumer),`
	`990`	`+ new PartitionContext(FullyQualifiedNamespace, EventHubName, ConsumerGroup, partitionId, transportConsumer),`
`991`	`991`	`receiveBatchSize,`
`992`	`992`	`exceptionCallback,`
`993`	`993`	`publishingCancellationSource.Token`