diff --git a/tests/KArtSell.Integration.Tests/OutboxPollerJobTests.cs b/tests/KArtSell.Integration.Tests/OutboxPollerJobTests.cs
index 738801b4..94c77c05 100644
--- a/tests/KArtSell.Integration.Tests/OutboxPollerJobTests.cs
+++ b/tests/KArtSell.Integration.Tests/OutboxPollerJobTests.cs
@@ -69,7 +69,11 @@ public sealed class OutboxPollerJobTests : IAsyncLifetime
         }
 
         var reader = new DapperOutboxMessageReader(_connectionFactory);
-        var job = new OutboxPollerJob(reader, _clock, _logger);
+        // Create a mock AuditTrailConsumer for testing
+        var mockAuditConsumer = new KArtSell.Host.Consumers.AuditTrailConsumer(
+            _connectionFactory,
+            Microsoft.Extensions.Logging.LoggerFactory.Create(b => { }).CreateLogger<KArtSell.Host.Consumers.AuditTrailConsumer>());
+        var job = new OutboxPollerJob(reader, _clock, _logger, _connectionFactory, mockAuditConsumer);
 
         // Act
         await job.ExecuteAsync(CancellationToken.None);
@@ -132,7 +136,11 @@ public sealed class OutboxPollerJobTests : IAsyncLifetime
         }
 
         var reader = new DapperOutboxMessageReader(_connectionFactory);
-        var job = new OutboxPollerJob(reader, _clock, _logger);
+        // Create a mock AuditTrailConsumer for testing
+        var mockAuditConsumer = new KArtSell.Host.Consumers.AuditTrailConsumer(
+            _connectionFactory,
+            Microsoft.Extensions.Logging.LoggerFactory.Create(b => { }).CreateLogger<KArtSell.Host.Consumers.AuditTrailConsumer>());
+        var job = new OutboxPollerJob(reader, _clock, _logger, _connectionFactory, mockAuditConsumer);
 
         // Act
         await job.ExecuteAsync(CancellationToken.None);