diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/ReactiveStateMachineExecutor.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/ReactiveStateMachineExecutor.java
index 26f063bf..93811fa7 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/ReactiveStateMachineExecutor.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/ReactiveStateMachineExecutor.java
@@ -125,7 +125,7 @@ public class ReactiveStateMachineExecutor<S, E> extends LifecycleObjectSupport i
 			Mono<Void> mono = startTriggers();
 
 			if (triggerDisposable == null) {
-				triggerDisposable = triggerFlux.subscribe();
+				triggerDisposable = triggerFlux.contextCapture().subscribe();
 			}
 
 			if (!initialHandled.getAndSet(true)) {