code review

Farfetch · Oct 12, 2023 · 1c0e18b · 1c0e18b
1 parent b0c1733
commit 1c0e18b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/KafkaFlow/Consumers/ConsumerWorker.cs b/src/KafkaFlow/Consumers/ConsumerWorker.cs
@@ -139,7 +139,7 @@ await this.middlewareExecutor
                 }
                 catch (Exception ex)
                 {
-                    await this.globalEvents.FireMessageConsumeErrorAsync(new MessageEventExceptionContext(context, ex));
+                    await this.globalEvents.FireMessageConsumeErrorAsync(new MessageErrorEventContext(context, ex));
 
                     this.logHandler.Error(
                         "Error processing message",

diff --git a/src/KafkaFlow/Producers/MessageProducer.cs b/src/KafkaFlow/Producers/MessageProducer.cs
@@ -42,7 +42,7 @@ public async Task<DeliveryResult<byte[], byte[]>> ProduceAsync(
 
             var messageContext = this.CreateMessageContext(topic, messageKey, messageValue, headers);
 
-            await this.globalEvents.FireMessageProduceStartedAsync(new MessageEventContext(messageContext, this.dependencyResolver));
+            await this.globalEvents.FireMessageProduceStartedAsync(new MessageEventContext(messageContext));
 
             await this.middlewareExecutor
                 .Execute(
@@ -56,7 +56,7 @@ await this.middlewareExecutor
                     })
                 .ConfigureAwait(false);
 
-            await this.globalEvents.FireMessageProduceCompletedAsync(new MessageEventContext(messageContext, this.dependencyResolver));
+            await this.globalEvents.FireMessageProduceCompletedAsync(new MessageEventContext(messageContext));
 
             return report;
         }
@@ -93,7 +93,7 @@ public void Produce(
 
             var messageContext = this.CreateMessageContext(topic, messageKey, messageValue, headers);
 
-            this.globalEvents.FireMessageProduceStartedAsync(new MessageEventContext(messageContext, this.dependencyResolver));
+            this.globalEvents.FireMessageProduceStartedAsync(new MessageEventContext(messageContext));
 
             this.middlewareExecutor
                 .Execute(
@@ -139,7 +139,7 @@ public void Produce(
                         scope.Dispose();
                     });
 
-            this.globalEvents.FireMessageProduceCompletedAsync(new MessageEventContext(messageContext, this.dependencyResolver));
+            this.globalEvents.FireMessageProduceCompletedAsync(new MessageEventContext(messageContext));
         }
 
         public void Produce(
@@ -283,7 +283,7 @@ private async Task<DeliveryResult<byte[], byte[]>> InternalProduceAsync(IMessage
             }
             catch (ProduceException<byte[], byte[]> e)
             {
-                await this.globalEvents.FireMessageProduceErrorAsync(new MessageEventExceptionContext(context, e));
+                await this.globalEvents.FireMessageProduceErrorAsync(new MessageErrorEventContext(context, e));
 
                 if (e.Error.IsFatal)
                 {