diff --git a/tests/RabbitMQ.ConsumerDataflowService/Program.cs b/tests/RabbitMQ.ConsumerDataflowService/Program.cs
index 67430b9..1d8aff4 100644
--- a/tests/RabbitMQ.ConsumerDataflowService/Program.cs
+++ b/tests/RabbitMQ.ConsumerDataflowService/Program.cs
@@ -26,7 +26,7 @@
 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);
@@ -34,7 +34,7 @@
         {
             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();
\ No newline at end of file
+await app.RunAsync();