fix message

agoda-com · Dec 22, 2023 · cf0794d · cf0794d
1 parent e7a7575
commit cf0794d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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;
     }
 }