codacy

Farfetch · Oct 14, 2023 · e80ebdc · e80ebdc
1 parent 0265472
commit e80ebdc
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/KafkaFlow.IntegrationTests/Core/Exceptions/ErrorExecutingMiddlewareException.cs b/src/KafkaFlow.IntegrationTests/Core/Exceptions/ErrorExecutingMiddlewareException.cs
@@ -2,7 +2,7 @@
 {
     using System;
 
-    internal class ErrorExecutingMiddlewareException : Exception
+    public class ErrorExecutingMiddlewareException : Exception
     {
         public ErrorExecutingMiddlewareException(string middlewareName)
             : base($"Exception thrown executing {middlewareName}")

diff --git a/src/KafkaFlow.IntegrationTests/Core/Exceptions/PartitionAssignmentException.cs b/src/KafkaFlow.IntegrationTests/Core/Exceptions/PartitionAssignmentException.cs
@@ -2,7 +2,7 @@
 {
     using System;
 
-    internal class PartitionAssignmentException : Exception
+    public class PartitionAssignmentException : Exception
     {
         private const string ExceptionMessage = "Partition assignment hasn't occurred yet.";
 

diff --git a/src/KafkaFlow.IntegrationTests/GlobalEventsTest.cs b/src/KafkaFlow.IntegrationTests/GlobalEventsTest.cs
@@ -177,7 +177,7 @@ private void ConfigureConsumer<T>(IConsumerConfigurationBuilder consumerConfigur
                     middlewares => middlewares
                         .AddSerializer<ProtobufNetSerializer>()
                         .Add<T>())
-                .WithPartitionsAssignedHandler((_, partitions) =>
+                .WithPartitionsAssignedHandler((_, _) =>
                 {
                     this.isPartitionAssigned = true;
                 });

diff --git a/src/KafkaFlow.IntegrationTests/OpenTelemetryTests.cs b/src/KafkaFlow.IntegrationTests/OpenTelemetryTests.cs
@@ -161,7 +161,7 @@ private async Task<IServiceProvider> GetServiceProvider()
                                                 middlewares => middlewares
                                                     .AddCompressor<GzipMessageCompressor>()
                                                     .Add<GzipMiddleware>())
-                                            .WithPartitionsAssignedHandler((_, partitions) =>
+                                            .WithPartitionsAssignedHandler((_, _) =>
                                             {
                                                 this.isPartitionAssigned = true;
                                             })))