Update Program.cs

houseofcat · Apr 23, 2024 · 01db50a · 01db50a
1 parent 6dece61
commit 01db50a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tests/RabbitMQ.ConsumerDataflowService/Program.cs b/tests/RabbitMQ.ConsumerDataflowService/Program.cs
@@ -26,15 +26,15 @@
 var dataflowService = new ConsumerDataflowService<CustomWorkState>(rabbitService, "TestConsumer");
 
 dataflowService.AddStep(
-    "write_message_to_console",
+    "write_message_to_log",
     (state) =>
     {
         var message = Encoding.UTF8.GetString(state.ReceivedMessage.Body.Span);
         if (message == "throw")
         {
             throw new Exception("Throwing an exception!");
         }
-        Console.WriteLine(message);
+        logger.LogInformation(message);
         return state;
     });
 
@@ -99,4 +99,4 @@
         logger.LogInformation("All stopped! Press return to exit...");
     });
 
-await app.RunAsync();
+await app.RunAsync();