diff --git a/FileProcessor.BusinessLogic.Tests/FileProcessorDomainServiceTests.cs b/FileProcessor.BusinessLogic.Tests/FileProcessorDomainServiceTests.cs
index 7227dfb..aff8156 100644
--- a/FileProcessor.BusinessLogic.Tests/FileProcessorDomainServiceTests.cs
+++ b/FileProcessor.BusinessLogic.Tests/FileProcessorDomainServiceTests.cs
@@ -661,13 +661,13 @@ public async Task FileRequestHandler_ProcessTransactionLineForFileRequest_LineIn
         this.FileAggregateRepository.SaveChanges(Arg<FileAggregate>.Any(), Arg<CancellationToken>.Any())
             .ReturnsAsync(Result.Success());
         FileCommands.ProcessTransactionForFileLineCommand processTransactionForFileLineRequest1 =
-            new (TestData.FileId, 1, TestData.FileLine1);
+            new (TestData.FileId, TestData.FileLineAddedEvent.EventId, 1, TestData.FileLine1);
         FileCommands.ProcessTransactionForFileLineCommand processTransactionForFileLineRequest2 =
-            new (TestData.FileId, 1, TestData.FileLine2);
+            new (TestData.FileId, TestData.FileLineAddedEvent.EventId, 1, TestData.FileLine2);
         FileCommands.ProcessTransactionForFileLineCommand processTransactionForFileLineRequest3 =
-            new (TestData.FileId, 3, TestData.FileLine3);
+            new (TestData.FileId, TestData.FileLineAddedEvent.EventId, 3, TestData.FileLine3);
         FileCommands.ProcessTransactionForFileLineCommand processTransactionForFileLineRequest4 =
-            new (TestData.FileId, 4, TestData.FileLine4);
+            new (TestData.FileId, TestData.FileLineAddedEvent.EventId, 4, TestData.FileLine4);
 
         var result1 = await this.FileProcessorDomainService.ProcessTransactionForFileLine(processTransactionForFileLineRequest1, CancellationToken.None);
         var result2 = await this.FileProcessorDomainService.ProcessTransactionForFileLine(processTransactionForFileLineRequest2, CancellationToken.None);
diff --git a/FileProcessor.BusinessLogic/EventHandling/FileDomainEventHandler.cs b/FileProcessor.BusinessLogic/EventHandling/FileDomainEventHandler.cs
index 85595fe..f1a5903 100644
--- a/FileProcessor.BusinessLogic/EventHandling/FileDomainEventHandler.cs
+++ b/FileProcessor.BusinessLogic/EventHandling/FileDomainEventHandler.cs
@@ -62,7 +62,7 @@ public async Task<Result> Handle(IDomainEvent domainEvent,
         private async Task<Result> HandleSpecificDomainEvent(FileLineAddedEvent domainEvent,
                                                     CancellationToken cancellationToken)
         {
-            FileCommands.ProcessTransactionForFileLineCommand command = new (domainEvent.FileId, domainEvent.LineNumber, domainEvent.FileLine);
+            FileCommands.ProcessTransactionForFileLineCommand command = new (domainEvent.FileId, domainEvent.EventId, domainEvent.LineNumber, domainEvent.FileLine);
             try
             {
                 Result result = await this.Mediator.Send(command, cancellationToken);
diff --git a/FileProcessor.BusinessLogic/Requests/FileCommands.cs b/FileProcessor.BusinessLogic/Requests/FileCommands.cs
index 228ccad..500ae85 100644
--- a/FileProcessor.BusinessLogic/Requests/FileCommands.cs
+++ b/FileProcessor.BusinessLogic/Requests/FileCommands.cs
@@ -7,7 +7,7 @@ namespace FileProcessor.BusinessLogic.Requests;
 
 [ExcludeFromCodeCoverage]
 public record FileCommands {
-    public record ProcessTransactionForFileLineCommand(Guid FileId, Int32 LineNumber, String FileLine)
+    public record ProcessTransactionForFileLineCommand(Guid FileId, Guid EventId, Int32 LineNumber, String FileLine)
         : IRequest<Result>;
 
     public record ProcessUploadedFileCommand(Guid EstateId,
diff --git a/FileProcessor.BusinessLogic/Services/FileProcessorDomainService.cs b/FileProcessor.BusinessLogic/Services/FileProcessorDomainService.cs
index a6f85ee..00190a5 100644
--- a/FileProcessor.BusinessLogic/Services/FileProcessorDomainService.cs
+++ b/FileProcessor.BusinessLogic/Services/FileProcessorDomainService.cs
@@ -452,7 +452,8 @@ private Result<Dictionary<String, String>> BuildTransactionMetadata(FileCommands
         // Add the file data to the request metadata
         transactionMetadata.Add("FileId", command.FileId.ToString());
         transactionMetadata.Add("FileLineNumber", fileLine.LineNumber.ToString());
-
+        transactionMetadata.Add("EventId", command.EventId.ToString());
+        
         operatorName = fileProfile.OperatorName;
         if (transactionMetadata.ContainsKey("OperatorName")) {
             // extract the value
diff --git a/FileProcessor.Testing/TestData.cs b/FileProcessor.Testing/TestData.cs
index 03bef31..0660d43 100644
--- a/FileProcessor.Testing/TestData.cs
+++ b/FileProcessor.Testing/TestData.cs
@@ -860,7 +860,7 @@ public static List<ContractResponse> GetMerchantContractsResponseNoNullValueProd
                                            TestData.FileUploadedDateTime);
         
         public static FileCommands.ProcessTransactionForFileLineCommand ProcessTransactionForFileLineCommand =>
-            new (TestData.FileId, TestData.LineNumber, TestData.FileLine);
+            new (TestData.FileId, TestData.FileLineAddedEvent.EventId, TestData.LineNumber, TestData.FileLine);
 
         public static FileQueries.GetFileQuery GetFileQuery => new(FileId, EstateId);