Merge branch 'release/2.7.1'

Author: MvRens

Tapeti.Cmd/ConsoleHelper/ConsoleWrapper.cs

@@ -144,7 +144,7 @@ public virtual void Dispose()
             public void Confirm(string message)
             {
                 WriteLine(message);
-                TryReadKey(false, out var _);
+                TryReadKey(false, out _);
             }
 
 

Tapeti.Cmd/Verbs/PurgeVerb.cs

@@ -1,5 +1,4 @@
-using System;
-using CommandLine;
+using CommandLine;
 using RabbitMQ.Client;
 using Tapeti.Cmd.ConsoleHelper;
 

Tapeti.Cmd/Verbs/RemoveQueueVerb.cs

@@ -1,5 +1,4 @@
-using System;
-using CommandLine;
+using CommandLine;
 using RabbitMQ.Client;
 using RabbitMQ.Client.Exceptions;
 using Tapeti.Cmd.ConsoleHelper;

Tapeti.Flow/Default/FlowStore.cs

@@ -30,7 +30,7 @@ public CachedFlowState(FlowState flowState, bool isPersistent)
         private readonly ConcurrentDictionary<Guid, CachedFlowState> flowStates = new ConcurrentDictionary<Guid, CachedFlowState>();
         private readonly ConcurrentDictionary<Guid, Guid> continuationLookup = new ConcurrentDictionary<Guid, Guid>();
         private readonly LockCollection<Guid> locks = new LockCollection<Guid>(EqualityComparer<Guid>.Default);
-        private HashSet<string> validatedMethods = null;
+        private HashSet<string> validatedMethods;
 
         private readonly IFlowRepository repository;
         private readonly ITapetiConfig config;

Tapeti.Flow/FlowHelpers/MethodSerializer.cs

@@ -1,5 +1,4 @@
-using System;
-using System.Reflection;
+using System.Reflection;
 using System.Text.RegularExpressions;
 
 namespace Tapeti.Flow.FlowHelpers

Tapeti/Config/IMessageContext.cs

@@ -1,6 +1,7 @@
 using System;
 
 // ReSharper disable UnusedMemberInSuper.Global - public API
+// ReSharper disable UnusedMember.Global
 
 namespace Tapeti.Config
 {

Tapeti/Connection/TapetiConsumer.cs

@@ -78,7 +78,8 @@ public async Task<ConsumeResult> Consume(string exchange, string routingKey, IMe
                 };
 
                 var exceptionContext = new ExceptionStrategyContext(emptyContext, dispatchException);
-                HandleException(exceptionContext);
+                await HandleException(exceptionContext);
+                
                 return exceptionContext.ConsumeResult;
             }
         }
@@ -132,15 +133,15 @@ await MiddlewareHelper.GoAsync(config.Middleware.Message,
             catch (Exception invokeException)
             {
                 var exceptionContext = new ExceptionStrategyContext(context, invokeException);
-                HandleException(exceptionContext);
+                await HandleException(exceptionContext);
 
                 await binding.Cleanup(context, exceptionContext.ConsumeResult);
                 return exceptionContext.ConsumeResult;
             }
         }
 
 
-        private void HandleException(ExceptionStrategyContext exceptionContext)
+        private async Task HandleException(ExceptionStrategyContext exceptionContext)
         {
             if (cancellationToken.IsCancellationRequested && IgnoreExceptionDuringShutdown(exceptionContext.Exception))
             {
@@ -151,7 +152,7 @@ private void HandleException(ExceptionStrategyContext exceptionContext)
 
             try
             {
-                exceptionStrategy.HandleException(exceptionContext);
+                await exceptionStrategy.HandleException(exceptionContext);
             }
             catch (Exception strategyException)
             {

Tapeti/Default/ConsoleLogger.cs

@@ -3,6 +3,8 @@
 using System.Text;
 using Tapeti.Config;
 
+// ReSharper disable UnusedMember.Global - public API
+
 namespace Tapeti.Default
 {
     /// <inheritdoc />
@@ -17,9 +19,6 @@ public class ConsoleLogger : IBindingLogger
         /// </summary>
         public class WithMessageLogging : ConsoleLogger
         {
-            /// <inheritdoc />
-            public WithMessageLogging() : base() { }
-
             internal override bool IncludeMessageBody() => true;
         }
 

Tapeti/Default/NackExceptionStrategy.cs

@@ -1,4 +1,5 @@
-using Tapeti.Config;
+using System.Threading.Tasks;
+using Tapeti.Config;
 
 namespace Tapeti.Default
 {
@@ -9,9 +10,10 @@ namespace Tapeti.Default
     public class NackExceptionStrategy : IExceptionStrategy
     {
         /// <inheritdoc />
-        public void HandleException(IExceptionStrategyContext context)
+        public Task HandleException(IExceptionStrategyContext context)
         {
             context.SetConsumeResult(ConsumeResult.Error);
+            return Task.CompletedTask;
         }
     }
 }

Tapeti/Default/RequeueExceptionStrategy.cs

@@ -1,4 +1,5 @@
-using Tapeti.Config;
+using System.Threading.Tasks;
+using Tapeti.Config;
 
 // ReSharper disable UnusedMember.Global
 
@@ -20,9 +21,10 @@ namespace Tapeti.Default
     public class RequeueExceptionStrategy : IExceptionStrategy
     {
         /// <inheritdoc />
-        public void HandleException(IExceptionStrategyContext context)
+        public Task HandleException(IExceptionStrategyContext context)
         {
             context.SetConsumeResult(ConsumeResult.Requeue);
+            return Task.CompletedTask;
         }
     }
 }

Tapeti/IExceptionStrategy.cs

@@ -1,4 +1,5 @@
-using Tapeti.Config;
+using System.Threading.Tasks;
+using Tapeti.Config;
 
 namespace Tapeti
 {
@@ -12,6 +13,6 @@ public interface IExceptionStrategy
         /// </summary>
         /// <param name="context">The exception strategy context containing the necessary data including the message context and the thrown exception.
         /// Also proivdes methods for the exception strategy to indicate how the message should be handled.</param>
-        void HandleException(IExceptionStrategyContext context);
+        Task HandleException(IExceptionStrategyContext context);
     }
 }