GitHub-Mirror/Tapeti
1
0
Fork 0
mirror of synced 2024-06-26 14:27:38 +00:00
Code Issues Projects Releases Wiki Activity

Ignore OperationCanceledException as well when shutting down

Browse Source
This commit is contained in:
Mark van Renswoude 2021-01-18 14:17:07 +01:00
parent 2431929ca3
commit 0b7c84a119
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
Tapeti/Connection/TapetiConsumer.cs
View File

@ -134,7 +134,7 @@ namespace Tapeti.Connection
private void HandleException(ExceptionStrategyContext exceptionContext) private void HandleException(ExceptionStrategyContext exceptionContext)
{ {
if (cancellationToken.IsCancellationRequested && IsTaskCanceledException(exceptionContext.Exception)) if (cancellationToken.IsCancellationRequested && IgnoreExceptionDuringShutdown(exceptionContext.Exception))
{ {
// The service is most likely stopping, and the connection is gone anyways. // The service is most likely stopping, and the connection is gone anyways.
exceptionContext.SetConsumeResult(ConsumeResult.Requeue); exceptionContext.SetConsumeResult(ConsumeResult.Requeue);
@ -156,18 +156,19 @@ namespace Tapeti.Connection
} }
private static bool IsTaskCanceledException(Exception e) private static bool IgnoreExceptionDuringShutdown(Exception e)
{ {
switch (e) switch (e)
{ {
case AggregateException aggregateException: case AggregateException aggregateException:
return aggregateException.InnerExceptions.Any(IsTaskCanceledException); return aggregateException.InnerExceptions.Any(IgnoreExceptionDuringShutdown);
case TaskCanceledException _: case TaskCanceledException _:
case OperationCanceledException _: // thrown by CancellationTokenSource.ThrowIfCancellationRequested
return true; return true;
default: default:
return e.InnerException != null && IsTaskCanceledException(e.InnerException); return e.InnerException != null && IgnoreExceptionDuringShutdown(e.InnerException);
} }
} }

1
Tapeti/Default/ControllerBindingContext.cs
View File

@ -155,7 +155,6 @@ namespace Tapeti.Default
public bool HasHandler => Handler != null; public bool HasHandler => Handler != null;
/// <inheritdoc />
public ControllerBindingResult(ParameterInfo info) public ControllerBindingResult(ParameterInfo info)
{ {
Info = info; Info = info;

1
Tapeti/Default/ControllerMethodBinding.cs
View File

@ -99,7 +99,6 @@ namespace Tapeti.Default
public MethodInfo Method => bindingInfo.Method; public MethodInfo Method => bindingInfo.Method;
/// <inheritdoc />
public ControllerMethodBinding(IDependencyResolver dependencyResolver, BindingInfo bindingInfo) public ControllerMethodBinding(IDependencyResolver dependencyResolver, BindingInfo bindingInfo)
{ {
this.dependencyResolver = dependencyResolver; this.dependencyResolver = dependencyResolver;