dbug: add a debug mode where we can see the messages received

uniteeio · Nov 8, 2022 · 95c252e · 95c252e
1 parent 3992ef3
commit 95c252e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/Unitee.EventDriven.RedisStream/RedisStreamBackgroundReceiver.cs b/Unitee.EventDriven.RedisStream/RedisStreamBackgroundReceiver.cs
@@ -10,7 +10,7 @@
 using Unitee.EventDriven.Attributes;
 using Unitee.RedisStream;
 
-namespace Unitee.EventDriven.DependencyInjection;
+namespace Unitee.EventDriven.RedisStream;
 
 public class RedisStreamBackgroundReceiver : BackgroundService
 {
@@ -49,6 +49,8 @@ private async Task<bool> TryConsume<TMessage>(TMessage message, string subjectRe
             return false;
         }
 
+        _logger.LogDebug("Consuming message {} with subject: {}", message, subjectRegistered);
+
         await consumer.ConsumeAsync(message);
         return true;
     }

diff --git a/Unitee.EventDriven.RedisStream/ServiceConfiguration.cs b/Unitee.EventDriven.RedisStream/ServiceConfiguration.cs
@@ -1,4 +1,5 @@
 using Microsoft.Extensions.DependencyInjection;
+using Unitee.EventDriven.RedisStream;
 
 namespace Unitee.EventDriven.DependencyInjection;