Add additional logging

BrighterCommand · Jan 7, 2025 · 651ee16 · 651ee16
1 parent b9ab92c
commit 651ee16
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumer.cs b/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumer.cs
@@ -283,9 +283,9 @@ public void Purge()
         /// </summary>
         public void Dispose()
         {
-            s_logger.LogInformation("Disposing the consumer...");
+            s_logger.LogInformation("Disposing the consumer for Channel {ChannelName}", _topicName);
             _serviceBusReceiver?.Close();
-            s_logger.LogInformation("Consumer disposed.");
+            s_logger.LogInformation("Consumer disposed for Channel {ChannelName}", _topicName);
         }
 
         private void GetMessageReceiverProvider()

diff --git a/src/Paramore.Brighter.ServiceActivator/MessagePump.cs b/src/Paramore.Brighter.ServiceActivator/MessagePump.cs
@@ -125,7 +125,9 @@ public void Run()
                 if (message == null)
                 {
                     Channel.Dispose();
-                    throw new Exception("Could not receive message. Note that should return an MT_NONE from an empty queue on timeout");
+                    var exception =  new Exception("Could not receive message. Note that should return an MT_NONE from an empty queue on timeout");
+                    s_logger.LogCritical(exception, "MessagePump: Could not receive message");
+                    throw exception;
                 }
 
                 // empty queue