From cf0794d72196cdf31dd2a58b481aeece874ea985 Mon Sep 17 00:00:00 2001
From: Joel Dickson <Joel.Dickson@agoda.com>
Date: Fri, 22 Dec 2023 14:35:15 +0700
Subject: [PATCH] fix message

---
 .../AppInsightsConsumerEventsHandler.cs                       | 4 ++--
 .../AppInsightsProducerEventsHandler.cs                       | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs b/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs
index aa6683d..3917055 100644
--- a/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs
+++ b/src/KafkaFlow.ApplicationInsights/AppInsightsConsumerEventsHandler.cs
@@ -26,7 +26,7 @@ public static Task OnConsumeError(IMessageContext eventContextMessageContext, Ex
         eventContextMessageContext.Items.TryGetValue("timer", out var timer);
         var theTimer = (Stopwatch)timer;
         theTimer.Stop();
-        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "500", false, theTimer.Elapsed);
+        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Error", false, theTimer.Elapsed);
         return Task.CompletedTask;
     }
 
@@ -38,7 +38,7 @@ internal static Task OnConsumeCompleted(IMessageContext eventContextMessageConte
         var theTimer = (Stopwatch)timer;
         theTimer.Stop();
         
-        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "200", true, theTimer.Elapsed);
+        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Ok", true, theTimer.Elapsed);
         return Task.CompletedTask;
     }
 }
diff --git a/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs b/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs
index b9677a1..5e1215d 100644
--- a/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs
+++ b/src/KafkaFlow.ApplicationInsights/AppInsightsProducerEventsHandler.cs
@@ -27,7 +27,7 @@ public static Task OnProducerError(IMessageContext eventContextMessageContext, E
         var theTimer = (Stopwatch)timer;
         theTimer.Stop();
 
-        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "500", false, theTimer.Elapsed);
+        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Error", false, theTimer.Elapsed);
         return Task.CompletedTask;
     }
 
@@ -39,7 +39,7 @@ public static Task OnProducerCompleted(IMessageContext eventContextMessageContex
         var theTimer = (Stopwatch)timer;
         theTimer.Stop();
 
-        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "200", true, theTimer.Elapsed);
+        telemetryClient.TrackKafkaDependency(eventContextMessageContext, "Ok", true, theTimer.Elapsed);
         return Task.CompletedTask;
     }
 }