소스 검색

Add try catch on Dispatcher.Processing when invoke subscriber (#900)

* Fix Dashboard metric not update #811

* Add try catch on Dispatcher.Processing when invoke subscriber
master
luox78 3 년 전
committed by GitHub
부모
커밋
1bc1595a97
No known key found for this signature in database GPG 키 ID: 4AEE18F83AFDEB23
1개의 변경된 파일9개의 추가작업 그리고 1개의 파일을 삭제
  1. +9
    -1
      src/DotNetCore.CAP/Processor/IDispatcher.Default.cs

+ 9
- 1
src/DotNetCore.CAP/Processor/IDispatcher.Default.cs 파일 보기

@@ -98,7 +98,15 @@ namespace DotNetCore.CAP.Processor
{
while (_receivedChannel.Reader.TryRead(out var message))
{
await _executor.DispatchAsync(message.Item1, message.Item2, _cts.Token);
try
{
await _executor.DispatchAsync(message.Item1, message.Item2, _cts.Token);
}
catch (Exception e)
{
_logger.LogError(e,
$"An exception occurred when invoke subscriber. MessageId:{message.Item1.DbId}");
}
}
}
}


불러오는 중...
취소
저장