Skip to content

C
CAP
Commit 1d7f2b19 authored by Savorboard's avatar Savorboard
Browse files
Options

refactor and modify logs content.

parent 05f6e661
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 9 deletions
src/DotNetCore.CAP/Processor/IDispatcher.Default.cs
View file @ 1d7f2b19
...@@ -65,7 +65,7 @@ namespace DotNetCore.CAP.Processor ...@@ -65,7 +65,7 @@ namespace DotNetCore.CAP.Processor
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.ExceptionOccuredWhileExecuting(message.Name, ex); _logger.LogError(ex, $"An exception occurred when sending a message to the MQ. Topic:{message.Name}, Id:{message.Id}");
} }
} }
} }
...@@ -81,16 +81,9 @@ namespace DotNetCore.CAP.Processor ...@@ -81,16 +81,9 @@ namespace DotNetCore.CAP.Processor
try try
{ {
foreach (var message in _receivedMessageQueue.GetConsumingEnumerable(_cts.Token)) foreach (var message in _receivedMessageQueue.GetConsumingEnumerable(_cts.Token))
{
try
{ {
_executor.ExecuteAsync(message); _executor.ExecuteAsync(message);
} }
catch (Exception ex)
{
_logger.ExceptionOccuredWhileExecuting(message.Name, ex);
}
}
} }
catch (OperationCanceledException) catch (OperationCanceledException)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment