diff --git a/src/Persistence/PersistenceTests/Marten/event_streaming.cs b/src/Persistence/PersistenceTests/Marten/event_streaming.cs
index 8d2bd253d..608d43552 100644
--- a/src/Persistence/PersistenceTests/Marten/event_streaming.cs
+++ b/src/Persistence/PersistenceTests/Marten/event_streaming.cs
@@ -61,7 +61,7 @@ public async Task InitializeAsync()
                 services.AddMarten(Servers.PostgresConnectionString)
                     .IntegrateWithWolverine("sender").EventForwardingToWolverine(opts =>
                     {
-                        opts.SubscribeToEvent<SecondEvent>().TransformedTo(e => new SecondMessage(e.Sequence));
+                        opts.SubscribeToEvent<SecondEvent>().TransformedTo(e => new SecondMessage(e.StreamId, e.Sequence));
                     });
                 
                 services.AddResourceSetupOnStartup();