diff --git a/src/MassTransit/BitzArt.MassTransit.ConsumerBase/ConsumerBase.cs b/src/MassTransit/BitzArt.MassTransit.ConsumerBase/ConsumerBase.cs index 26f7b87..f3ab395 100644 --- a/src/MassTransit/BitzArt.MassTransit.ConsumerBase/ConsumerBase.cs +++ b/src/MassTransit/BitzArt.MassTransit.ConsumerBase/ConsumerBase.cs @@ -35,7 +35,7 @@ public virtual async Task Consume(ConsumeContext context) Logger.LogError("Message processing failed: {error}", ex.Message); throw; } - Logger.LogInformation("Message has been processed successfully: {ms}ms.", sw.ElapsedMilliseconds); + Logger.LogInformation("Message has been processed successfully in {ms}ms.", sw.ElapsedMilliseconds); sw.Stop(); await OnAfterConsuming(context); @@ -58,7 +58,7 @@ public virtual Task Consume(ConsumeContext> context) { WriteIndented = true }); - Logger.LogError("Message processing attempt failed. Errors:\n{json}", json); + Logger.LogError("Message processing failed after {count} attempts. Errors:\n{json}", errors.Count(), json); return Task.CompletedTask; } }