diff --git a/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumer.cs b/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumer.cs index c0d94aee62..10032e9f28 100644 --- a/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumer.cs +++ b/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumer.cs @@ -283,9 +283,9 @@ public void Purge() /// 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 index 6933af14a7..e25591acaf 100644 --- 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