Move ConsumeAndProcessMessageHandler to Confluent.Kafka namespace

Author: g7ed6e

src/OpenTelemetry.Instrumentation.ConfluentKafka/ConsumeAndProcessMessageHandler.cs renamed to src/OpenTelemetry.Instrumentation.ConfluentKafka/OpenTelemetryConsumeAndProcessMessageHandler.cs

@@ -2,9 +2,8 @@
 // SPDX-License-Identifier: Apache-2.0
 
 using System.Diagnostics;
-using Confluent.Kafka;
 
-namespace OpenTelemetry.Instrumentation.ConfluentKafka;
+namespace Confluent.Kafka;
 
 /// <summary>
 /// An asynchronous action to process the <see cref="ConsumeResult{TKey,TValue}"/>.
@@ -15,7 +14,7 @@ namespace OpenTelemetry.Instrumentation.ConfluentKafka;
 /// <typeparam name="TKey">The type of key of the <see cref="ConsumeResult{TKey,TValue}"/>.</typeparam>
 /// <typeparam name="TValue">The type of value of the <see cref="ConsumeResult{TKey,TValue}"/>.</typeparam>
 /// <returns>A <see cref="ValueTask"/>.</returns>
-public delegate ValueTask ConsumeAndProcessMessageHandler<TKey, TValue>(
+public delegate ValueTask OpenTelemetryConsumeAndProcessMessageHandler<TKey, TValue>(
     ConsumeResult<TKey, TValue> consumeResult,
     Activity? activity,
     CancellationToken cancellationToken = default);

src/OpenTelemetry.Instrumentation.ConfluentKafka/OpenTelemetryConsumeResultExtensions.cs

@@ -49,30 +49,30 @@ public static bool TryExtractPropagationContext<TKey, TValue>(
     }
 
     /// <summary>
-    /// Consumes a message and creates <see href="https://github.com/open-telemetry/semantic-conventions/blob/main/docs/messaging/messaging-spans.md#span-kind">a process span</see> embracing the <see cref="ConsumeAndProcessMessageHandler{TKey,TValue}"/>.
+    /// Consumes a message and creates <see href="https://github.com/open-telemetry/semantic-conventions/blob/main/docs/messaging/messaging-spans.md#span-kind">a process span</see> embracing the <see cref="OpenTelemetryConsumeAndProcessMessageHandler{TKey,TValue}"/>.
     /// </summary>
     /// <param name="consumer">The <see cref="IConsumer{TKey,TValue}"/>.</param>
-    /// <param name="handler">A <see cref="ConsumeAndProcessMessageHandler{TKey,TValue}"/>.</param>
+    /// <param name="handler">A <see cref="OpenTelemetryConsumeAndProcessMessageHandler{TKey,TValue}"/>.</param>
     /// <typeparam name="TKey">The type of key of the <see cref="ConsumeResult{TKey,TValue}"/>.</typeparam>
     /// <typeparam name="TValue">The type of value of the <see cref="ConsumeResult{TKey,TValue}"/>.</typeparam>
     /// <returns>A <see cref="ValueTask"/>.</returns>
     public static ValueTask<ConsumeResult<TKey, TValue>?> ConsumeAndProcessMessageAsync<TKey, TValue>(
         this IConsumer<TKey, TValue> consumer,
-        ConsumeAndProcessMessageHandler<TKey, TValue> handler) =>
+        OpenTelemetryConsumeAndProcessMessageHandler<TKey, TValue> handler) =>
         ConsumeAndProcessMessageAsync(consumer, handler, default);
 
     /// <summary>
-    /// Consumes a message and creates <see href="https://github.com/open-telemetry/semantic-conventions/blob/main/docs/messaging/messaging-spans.md#span-kind">a process span</see> embracing the <see cref="ConsumeAndProcessMessageHandler{TKey,TValue}"/>.
+    /// Consumes a message and creates <see href="https://github.com/open-telemetry/semantic-conventions/blob/main/docs/messaging/messaging-spans.md#span-kind">a process span</see> embracing the <see cref="OpenTelemetryConsumeAndProcessMessageHandler{TKey,TValue}"/>.
     /// </summary>
     /// <param name="consumer">The <see cref="IConsumer{TKey,TValue}"/>.</param>
-    /// <param name="handler">A <see cref="ConsumeAndProcessMessageHandler{TKey,TValue}"/>.</param>
+    /// <param name="handler">A <see cref="OpenTelemetryConsumeAndProcessMessageHandler{TKey,TValue}"/>.</param>
     /// <param name="cancellationToken">An optional <see cref="CancellationToken"/>.</param>
     /// <typeparam name="TKey">The type of key of the <see cref="ConsumeResult{TKey,TValue}"/>.</typeparam>
     /// <typeparam name="TValue">The type of value of the <see cref="ConsumeResult{TKey,TValue}"/>.</typeparam>
     /// <returns>A <see cref="ValueTask"/>.</returns>
     public static async ValueTask<ConsumeResult<TKey, TValue>?> ConsumeAndProcessMessageAsync<TKey, TValue>(
         this IConsumer<TKey, TValue> consumer,
-        ConsumeAndProcessMessageHandler<TKey, TValue> handler,
+        OpenTelemetryConsumeAndProcessMessageHandler<TKey, TValue> handler,
         CancellationToken cancellationToken)
     {
 #if NETFRAMEWORK