diff --git a/src/NServiceBus.Extensions.IntegrationTesting/EndpointFixture.cs b/src/NServiceBus.Extensions.IntegrationTesting/EndpointFixture.cs
index 3e917f7..3fdf308 100644
--- a/src/NServiceBus.Extensions.IntegrationTesting/EndpointFixture.cs
+++ b/src/NServiceBus.Extensions.IntegrationTesting/EndpointFixture.cs
@@ -101,7 +101,7 @@ private static async Task<ObservedMessageContexts> ExecuteAndWait<TMessageContex
 
                         break;
                     case NsbActivityNames.InvokeHandlerActivityName:
-                        var handlerContext = activitySource.GetTagItem("testing.invoke.handler.context") as IInvokeHandlerContext;
+                        var handlerContext = activitySource.Parent.GetTagItem("testing.invoke.handler.context") as IInvokeHandlerContext;
                      
                         invokeHandlerContexts.Add(handlerContext);