fixes

Farfetch · Oct 30, 2023 · ae1c60e · ae1c60e
1 parent 821b245
commit ae1c60e
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/KafkaFlow/Consumers/ConsumerWorker.cs b/src/KafkaFlow/Consumers/ConsumerWorker.cs
@@ -131,7 +131,7 @@ private async Task ProcessMessageAsync(IMessageContext context, CancellationToke
                 {
                     await this.globalEvents.FireMessageConsumeStartedAsync(new MessageEventContext(context));
 
-                    await context.ConsumerContext.Completion.ContinueWith(
+                    _= context.ConsumerContext.Completion.ContinueWith(
                         async task =>
                         {
                             if (task.IsFaulted)
@@ -145,8 +145,6 @@ await context.ConsumerContext.Completion.ContinueWith(
                     await this.middlewareExecutor
                         .Execute(context, _ => Task.CompletedTask)
                         .ConfigureAwait(false);
-
-                    await this.globalEvents.FireMessageConsumeCompletedAsync(new MessageEventContext(context));
                 }
                 catch (OperationCanceledException) when (cancellationToken.IsCancellationRequested)
                 {