renamed otel consumer and producer

Farfetch · Oct 12, 2023 · 02572b1 · 02572b1
1 parent c458d2f
commit 02572b1
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/src/KafkaFlow.OpenTelemetry/ExtensionMethods.cs b/src/KafkaFlow.OpenTelemetry/ExtensionMethods.cs
@@ -18,32 +18,32 @@ public static IKafkaConfigurationBuilder AddOpenTelemetryInstrumentation(this IK
             {
                 hub.MessageConsumeStarted.Subscribe(eventContext =>
                 {
-                    return OpenTelemetryConsumerObserver.OnConsumeStarted(eventContext.MessageContext);
+                    return OpenTelemetryConsumerEventsHandler.OnConsumeStarted(eventContext.MessageContext);
                 });
 
                 hub.MessageConsumeError.Subscribe(eventContext =>
                 {
-                    return OpenTelemetryConsumerObserver.OnConsumeError(eventContext.MessageContext, eventContext.Exception);
+                    return OpenTelemetryConsumerEventsHandler.OnConsumeError(eventContext.MessageContext, eventContext.Exception);
                 });
 
                 hub.MessageConsumeCompleted.Subscribe(eventContext =>
                 {
-                    return OpenTelemetryConsumerObserver.OnConsumeCompleted(eventContext.MessageContext);
+                    return OpenTelemetryConsumerEventsHandler.OnConsumeCompleted(eventContext.MessageContext);
                 });
 
                 hub.MessageProduceStarted.Subscribe(eventContext =>
                 {
-                    return OpenTelemetryProducerObserver.OnProducerStarted(eventContext.MessageContext);
+                    return OpenTelemetryProducerEventsHandler.OnProducerStarted(eventContext.MessageContext);
                 });
 
                 hub.MessageProduceError.Subscribe(eventContext =>
                 {
-                    return OpenTelemetryProducerObserver.OnProducerError(eventContext.MessageContext, eventContext.Exception);
+                    return OpenTelemetryProducerEventsHandler.OnProducerError(eventContext.MessageContext, eventContext.Exception);
                 });
 
                 hub.MessageProduceCompleted.Subscribe(eventContext =>
                 {
-                    return OpenTelemetryProducerObserver.OnProducerCompleted(eventContext.MessageContext);
+                    return OpenTelemetryProducerEventsHandler.OnProducerCompleted(eventContext.MessageContext);
                 });
             });
 

diff --git a/...elemetry/OpenTelemetryConsumerObserver.cs → ...try/OpenTelemetryConsumerEventsHandler.cs b/...elemetry/OpenTelemetryConsumerObserver.cs → ...try/OpenTelemetryConsumerEventsHandler.cs
@@ -8,7 +8,7 @@
     using global::OpenTelemetry;
     using global::OpenTelemetry.Context.Propagation;
 
-    internal static class OpenTelemetryConsumerObserver
+    internal static class OpenTelemetryConsumerEventsHandler
     {
         private static readonly TextMapPropagator Propagator = Propagators.DefaultTextMapPropagator;
         private static readonly string ProcessString = "process";

diff --git a/...elemetry/OpenTelemetryProducerObserver.cs → ...try/OpenTelemetryProducerEventsHandler.cs b/...elemetry/OpenTelemetryProducerObserver.cs → ...try/OpenTelemetryProducerEventsHandler.cs
@@ -8,7 +8,7 @@
     using global::OpenTelemetry;
     using global::OpenTelemetry.Context.Propagation;
 
-    internal static class OpenTelemetryProducerObserver
+    internal static class OpenTelemetryProducerEventsHandler
     {
         private static readonly TextMapPropagator Propagator = Propagators.DefaultTextMapPropagator;
         private static readonly string PublishString = "publish";